// Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. package qldbsession import ( "fmt" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/awsutil" "github.com/aws/aws-sdk-go/aws/request" "github.com/aws/aws-sdk-go/private/protocol" ) const opSendCommand = "SendCommand" // SendCommandRequest generates a "aws/request.Request" representing the // client's request for the SendCommand operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See SendCommand for more information on using the SendCommand // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the SendCommandRequest method. // req, resp := client.SendCommandRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/qldb-session-2019-07-11/SendCommand func (c *QLDBSession) SendCommandRequest(input *SendCommandInput) (req *request.Request, output *SendCommandOutput) { op := &request.Operation{ Name: opSendCommand, HTTPMethod: "POST", HTTPPath: "/", } if input == nil { input = &SendCommandInput{} } output = &SendCommandOutput{} req = c.newRequest(op, input, output) return } // SendCommand API operation for Amazon QLDB Session. // // Sends a command to an Amazon QLDB ledger. // // Instead of interacting directly with this API, we recommend using the QLDB // driver or the QLDB shell to execute data transactions on a ledger. // // - If you are working with an AWS SDK, use the QLDB driver. The driver // provides a high-level abstraction layer above this QLDB Session data plane // and manages SendCommand API calls for you. For information and a list // of supported programming languages, see Getting started with the driver // (https://docs.aws.amazon.com/qldb/latest/developerguide/getting-started-driver.html) // in the Amazon QLDB Developer Guide. // // - If you are working with the AWS Command Line Interface (AWS CLI), use // the QLDB shell. The shell is a command line interface that uses the QLDB // driver to interact with a ledger. For information, see Accessing Amazon // QLDB using the QLDB shell (https://docs.aws.amazon.com/qldb/latest/developerguide/data-shell.html). // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon QLDB Session's // API operation SendCommand for usage and error information. // // Returned Error Types: // // - BadRequestException // Returned if the request is malformed or contains an error such as an invalid // parameter value or a missing required parameter. // // - InvalidSessionException // Returned if the session doesn't exist anymore because it timed out or expired. // // - OccConflictException // Returned when a transaction cannot be written to the journal due to a failure // in the verification phase of optimistic concurrency control (OCC). // // - RateExceededException // Returned when the rate of requests exceeds the allowed throughput. // // - LimitExceededException // Returned if a resource limit such as number of active sessions is exceeded. // // - CapacityExceededException // Returned when the request exceeds the processing capacity of the ledger. // // See also, https://docs.aws.amazon.com/goto/WebAPI/qldb-session-2019-07-11/SendCommand func (c *QLDBSession) SendCommand(input *SendCommandInput) (*SendCommandOutput, error) { req, out := c.SendCommandRequest(input) return out, req.Send() } // SendCommandWithContext is the same as SendCommand with the addition of // the ability to pass a context and additional request options. // // See SendCommand for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c *QLDBSession) SendCommandWithContext(ctx aws.Context, input *SendCommandInput, opts ...request.Option) (*SendCommandOutput, error) { req, out := c.SendCommandRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } // Contains the details of the transaction to abort. type AbortTransactionRequest struct { _ struct{} `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s AbortTransactionRequest) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s AbortTransactionRequest) GoString() string { return s.String() } // Contains the details of the aborted transaction. type AbortTransactionResult struct { _ struct{} `type:"structure"` // Contains server-side performance information for the command. TimingInformation *TimingInformation `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s AbortTransactionResult) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s AbortTransactionResult) GoString() string { return s.String() } // SetTimingInformation sets the TimingInformation field's value. func (s *AbortTransactionResult) SetTimingInformation(v *TimingInformation) *AbortTransactionResult { s.TimingInformation = v return s } // Returned if the request is malformed or contains an error such as an invalid // parameter value or a missing required parameter. type BadRequestException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ *string `locationName:"Code" type:"string"` Message_ *string `locationName:"Message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s BadRequestException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s BadRequestException) GoString() string { return s.String() } func newErrorBadRequestException(v protocol.ResponseMetadata) error { return &BadRequestException{ RespMetadata: v, } } // Code returns the exception type name. func (s *BadRequestException) Code() string { return "BadRequestException" } // Message returns the exception's message. func (s *BadRequestException) Message() string { if s.Message_ != nil { return *s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s *BadRequestException) OrigErr() error { return nil } func (s *BadRequestException) Error() string { return fmt.Sprintf("%s: %s\n%s", s.Code(), s.Message(), s.String()) } // Status code returns the HTTP status code for the request's response error. func (s *BadRequestException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s *BadRequestException) RequestID() string { return s.RespMetadata.RequestID } // Returned when the request exceeds the processing capacity of the ledger. type CapacityExceededException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ *string `locationName:"Message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CapacityExceededException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CapacityExceededException) GoString() string { return s.String() } func newErrorCapacityExceededException(v protocol.ResponseMetadata) error { return &CapacityExceededException{ RespMetadata: v, } } // Code returns the exception type name. func (s *CapacityExceededException) Code() string { return "CapacityExceededException" } // Message returns the exception's message. func (s *CapacityExceededException) Message() string { if s.Message_ != nil { return *s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s *CapacityExceededException) OrigErr() error { return nil } func (s *CapacityExceededException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s *CapacityExceededException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s *CapacityExceededException) RequestID() string { return s.RespMetadata.RequestID } // Contains the details of the transaction to commit. type CommitTransactionRequest struct { _ struct{} `type:"structure"` // Specifies the commit digest for the transaction to commit. For every active // transaction, the commit digest must be passed. QLDB validates CommitDigest // and rejects the commit with an error if the digest computed on the client // does not match the digest computed by QLDB. // // The purpose of the CommitDigest parameter is to ensure that QLDB commits // a transaction if and only if the server has processed the exact set of statements // sent by the client, in the same order that client sent them, and with no // duplicates. // CommitDigest is automatically base64 encoded/decoded by the SDK. // // CommitDigest is a required field CommitDigest []byte `type:"blob" required:"true"` // Specifies the transaction ID of the transaction to commit. // // TransactionId is a required field TransactionId *string `min:"22" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CommitTransactionRequest) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CommitTransactionRequest) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *CommitTransactionRequest) Validate() error { invalidParams := request.ErrInvalidParams{Context: "CommitTransactionRequest"} if s.CommitDigest == nil { invalidParams.Add(request.NewErrParamRequired("CommitDigest")) } if s.TransactionId == nil { invalidParams.Add(request.NewErrParamRequired("TransactionId")) } if s.TransactionId != nil && len(*s.TransactionId) < 22 { invalidParams.Add(request.NewErrParamMinLen("TransactionId", 22)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetCommitDigest sets the CommitDigest field's value. func (s *CommitTransactionRequest) SetCommitDigest(v []byte) *CommitTransactionRequest { s.CommitDigest = v return s } // SetTransactionId sets the TransactionId field's value. func (s *CommitTransactionRequest) SetTransactionId(v string) *CommitTransactionRequest { s.TransactionId = &v return s } // Contains the details of the committed transaction. type CommitTransactionResult struct { _ struct{} `type:"structure"` // The commit digest of the committed transaction. // CommitDigest is automatically base64 encoded/decoded by the SDK. CommitDigest []byte `type:"blob"` // Contains metrics about the number of I/O requests that were consumed. ConsumedIOs *IOUsage `type:"structure"` // Contains server-side performance information for the command. TimingInformation *TimingInformation `type:"structure"` // The transaction ID of the committed transaction. TransactionId *string `min:"22" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CommitTransactionResult) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s CommitTransactionResult) GoString() string { return s.String() } // SetCommitDigest sets the CommitDigest field's value. func (s *CommitTransactionResult) SetCommitDigest(v []byte) *CommitTransactionResult { s.CommitDigest = v return s } // SetConsumedIOs sets the ConsumedIOs field's value. func (s *CommitTransactionResult) SetConsumedIOs(v *IOUsage) *CommitTransactionResult { s.ConsumedIOs = v return s } // SetTimingInformation sets the TimingInformation field's value. func (s *CommitTransactionResult) SetTimingInformation(v *TimingInformation) *CommitTransactionResult { s.TimingInformation = v return s } // SetTransactionId sets the TransactionId field's value. func (s *CommitTransactionResult) SetTransactionId(v string) *CommitTransactionResult { s.TransactionId = &v return s } // Specifies a request to end the session. type EndSessionRequest struct { _ struct{} `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s EndSessionRequest) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s EndSessionRequest) GoString() string { return s.String() } // Contains the details of the ended session. type EndSessionResult struct { _ struct{} `type:"structure"` // Contains server-side performance information for the command. TimingInformation *TimingInformation `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s EndSessionResult) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s EndSessionResult) GoString() string { return s.String() } // SetTimingInformation sets the TimingInformation field's value. func (s *EndSessionResult) SetTimingInformation(v *TimingInformation) *EndSessionResult { s.TimingInformation = v return s } // Specifies a request to execute a statement. type ExecuteStatementRequest struct { _ struct{} `type:"structure"` // Specifies the parameters for the parameterized statement in the request. Parameters []*ValueHolder `type:"list"` // Specifies the statement of the request. // // Statement is a required field Statement *string `min:"1" type:"string" required:"true"` // Specifies the transaction ID of the request. // // TransactionId is a required field TransactionId *string `min:"22" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ExecuteStatementRequest) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ExecuteStatementRequest) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ExecuteStatementRequest) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ExecuteStatementRequest"} if s.Statement == nil { invalidParams.Add(request.NewErrParamRequired("Statement")) } if s.Statement != nil && len(*s.Statement) < 1 { invalidParams.Add(request.NewErrParamMinLen("Statement", 1)) } if s.TransactionId == nil { invalidParams.Add(request.NewErrParamRequired("TransactionId")) } if s.TransactionId != nil && len(*s.TransactionId) < 22 { invalidParams.Add(request.NewErrParamMinLen("TransactionId", 22)) } if s.Parameters != nil { for i, v := range s.Parameters { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "Parameters", i), err.(request.ErrInvalidParams)) } } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetParameters sets the Parameters field's value. func (s *ExecuteStatementRequest) SetParameters(v []*ValueHolder) *ExecuteStatementRequest { s.Parameters = v return s } // SetStatement sets the Statement field's value. func (s *ExecuteStatementRequest) SetStatement(v string) *ExecuteStatementRequest { s.Statement = &v return s } // SetTransactionId sets the TransactionId field's value. func (s *ExecuteStatementRequest) SetTransactionId(v string) *ExecuteStatementRequest { s.TransactionId = &v return s } // Contains the details of the executed statement. type ExecuteStatementResult struct { _ struct{} `type:"structure"` // Contains metrics about the number of I/O requests that were consumed. ConsumedIOs *IOUsage `type:"structure"` // Contains the details of the first fetched page. FirstPage *Page `type:"structure"` // Contains server-side performance information for the command. TimingInformation *TimingInformation `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ExecuteStatementResult) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ExecuteStatementResult) GoString() string { return s.String() } // SetConsumedIOs sets the ConsumedIOs field's value. func (s *ExecuteStatementResult) SetConsumedIOs(v *IOUsage) *ExecuteStatementResult { s.ConsumedIOs = v return s } // SetFirstPage sets the FirstPage field's value. func (s *ExecuteStatementResult) SetFirstPage(v *Page) *ExecuteStatementResult { s.FirstPage = v return s } // SetTimingInformation sets the TimingInformation field's value. func (s *ExecuteStatementResult) SetTimingInformation(v *TimingInformation) *ExecuteStatementResult { s.TimingInformation = v return s } // Specifies the details of the page to be fetched. type FetchPageRequest struct { _ struct{} `type:"structure"` // Specifies the next page token of the page to be fetched. // // NextPageToken is a required field NextPageToken *string `min:"4" type:"string" required:"true"` // Specifies the transaction ID of the page to be fetched. // // TransactionId is a required field TransactionId *string `min:"22" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s FetchPageRequest) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s FetchPageRequest) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *FetchPageRequest) Validate() error { invalidParams := request.ErrInvalidParams{Context: "FetchPageRequest"} if s.NextPageToken == nil { invalidParams.Add(request.NewErrParamRequired("NextPageToken")) } if s.NextPageToken != nil && len(*s.NextPageToken) < 4 { invalidParams.Add(request.NewErrParamMinLen("NextPageToken", 4)) } if s.TransactionId == nil { invalidParams.Add(request.NewErrParamRequired("TransactionId")) } if s.TransactionId != nil && len(*s.TransactionId) < 22 { invalidParams.Add(request.NewErrParamMinLen("TransactionId", 22)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetNextPageToken sets the NextPageToken field's value. func (s *FetchPageRequest) SetNextPageToken(v string) *FetchPageRequest { s.NextPageToken = &v return s } // SetTransactionId sets the TransactionId field's value. func (s *FetchPageRequest) SetTransactionId(v string) *FetchPageRequest { s.TransactionId = &v return s } // Contains the page that was fetched. type FetchPageResult struct { _ struct{} `type:"structure"` // Contains metrics about the number of I/O requests that were consumed. ConsumedIOs *IOUsage `type:"structure"` // Contains details of the fetched page. Page *Page `type:"structure"` // Contains server-side performance information for the command. TimingInformation *TimingInformation `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s FetchPageResult) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s FetchPageResult) GoString() string { return s.String() } // SetConsumedIOs sets the ConsumedIOs field's value. func (s *FetchPageResult) SetConsumedIOs(v *IOUsage) *FetchPageResult { s.ConsumedIOs = v return s } // SetPage sets the Page field's value. func (s *FetchPageResult) SetPage(v *Page) *FetchPageResult { s.Page = v return s } // SetTimingInformation sets the TimingInformation field's value. func (s *FetchPageResult) SetTimingInformation(v *TimingInformation) *FetchPageResult { s.TimingInformation = v return s } // Contains I/O usage metrics for a command that was invoked. type IOUsage struct { _ struct{} `type:"structure"` // The number of read I/O requests that the command made. ReadIOs *int64 `type:"long"` // The number of write I/O requests that the command made. WriteIOs *int64 `type:"long"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s IOUsage) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s IOUsage) GoString() string { return s.String() } // SetReadIOs sets the ReadIOs field's value. func (s *IOUsage) SetReadIOs(v int64) *IOUsage { s.ReadIOs = &v return s } // SetWriteIOs sets the WriteIOs field's value. func (s *IOUsage) SetWriteIOs(v int64) *IOUsage { s.WriteIOs = &v return s } // Returned if the session doesn't exist anymore because it timed out or expired. type InvalidSessionException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Code_ *string `locationName:"Code" type:"string"` Message_ *string `locationName:"Message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidSessionException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidSessionException) GoString() string { return s.String() } func newErrorInvalidSessionException(v protocol.ResponseMetadata) error { return &InvalidSessionException{ RespMetadata: v, } } // Code returns the exception type name. func (s *InvalidSessionException) Code() string { return "InvalidSessionException" } // Message returns the exception's message. func (s *InvalidSessionException) Message() string { if s.Message_ != nil { return *s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s *InvalidSessionException) OrigErr() error { return nil } func (s *InvalidSessionException) Error() string { return fmt.Sprintf("%s: %s\n%s", s.Code(), s.Message(), s.String()) } // Status code returns the HTTP status code for the request's response error. func (s *InvalidSessionException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s *InvalidSessionException) RequestID() string { return s.RespMetadata.RequestID } // Returned if a resource limit such as number of active sessions is exceeded. type LimitExceededException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ *string `locationName:"Message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s LimitExceededException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s LimitExceededException) GoString() string { return s.String() } func newErrorLimitExceededException(v protocol.ResponseMetadata) error { return &LimitExceededException{ RespMetadata: v, } } // Code returns the exception type name. func (s *LimitExceededException) Code() string { return "LimitExceededException" } // Message returns the exception's message. func (s *LimitExceededException) Message() string { if s.Message_ != nil { return *s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s *LimitExceededException) OrigErr() error { return nil } func (s *LimitExceededException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s *LimitExceededException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s *LimitExceededException) RequestID() string { return s.RespMetadata.RequestID } // Returned when a transaction cannot be written to the journal due to a failure // in the verification phase of optimistic concurrency control (OCC). type OccConflictException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ *string `locationName:"Message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s OccConflictException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s OccConflictException) GoString() string { return s.String() } func newErrorOccConflictException(v protocol.ResponseMetadata) error { return &OccConflictException{ RespMetadata: v, } } // Code returns the exception type name. func (s *OccConflictException) Code() string { return "OccConflictException" } // Message returns the exception's message. func (s *OccConflictException) Message() string { if s.Message_ != nil { return *s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s *OccConflictException) OrigErr() error { return nil } func (s *OccConflictException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s *OccConflictException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s *OccConflictException) RequestID() string { return s.RespMetadata.RequestID } // Contains details of the fetched page. type Page struct { _ struct{} `type:"structure"` // The token of the next page. NextPageToken *string `min:"4" type:"string"` // A structure that contains values in multiple encoding formats. Values []*ValueHolder `type:"list"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s Page) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s Page) GoString() string { return s.String() } // SetNextPageToken sets the NextPageToken field's value. func (s *Page) SetNextPageToken(v string) *Page { s.NextPageToken = &v return s } // SetValues sets the Values field's value. func (s *Page) SetValues(v []*ValueHolder) *Page { s.Values = v return s } // Returned when the rate of requests exceeds the allowed throughput. type RateExceededException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ *string `locationName:"Message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s RateExceededException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s RateExceededException) GoString() string { return s.String() } func newErrorRateExceededException(v protocol.ResponseMetadata) error { return &RateExceededException{ RespMetadata: v, } } // Code returns the exception type name. func (s *RateExceededException) Code() string { return "RateExceededException" } // Message returns the exception's message. func (s *RateExceededException) Message() string { if s.Message_ != nil { return *s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s *RateExceededException) OrigErr() error { return nil } func (s *RateExceededException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s *RateExceededException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s *RateExceededException) RequestID() string { return s.RespMetadata.RequestID } type SendCommandInput struct { _ struct{} `type:"structure"` // Command to abort the current transaction. AbortTransaction *AbortTransactionRequest `type:"structure"` // Command to commit the specified transaction. CommitTransaction *CommitTransactionRequest `type:"structure"` // Command to end the current session. EndSession *EndSessionRequest `type:"structure"` // Command to execute a statement in the specified transaction. ExecuteStatement *ExecuteStatementRequest `type:"structure"` // Command to fetch a page. FetchPage *FetchPageRequest `type:"structure"` // Specifies the session token for the current command. A session token is constant // throughout the life of the session. // // To obtain a session token, run the StartSession command. This SessionToken // is required for every subsequent command that is issued during the current // session. SessionToken *string `min:"4" type:"string"` // Command to start a new session. A session token is obtained as part of the // response. StartSession *StartSessionRequest `type:"structure"` // Command to start a new transaction. StartTransaction *StartTransactionRequest `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SendCommandInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SendCommandInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *SendCommandInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "SendCommandInput"} if s.SessionToken != nil && len(*s.SessionToken) < 4 { invalidParams.Add(request.NewErrParamMinLen("SessionToken", 4)) } if s.CommitTransaction != nil { if err := s.CommitTransaction.Validate(); err != nil { invalidParams.AddNested("CommitTransaction", err.(request.ErrInvalidParams)) } } if s.ExecuteStatement != nil { if err := s.ExecuteStatement.Validate(); err != nil { invalidParams.AddNested("ExecuteStatement", err.(request.ErrInvalidParams)) } } if s.FetchPage != nil { if err := s.FetchPage.Validate(); err != nil { invalidParams.AddNested("FetchPage", err.(request.ErrInvalidParams)) } } if s.StartSession != nil { if err := s.StartSession.Validate(); err != nil { invalidParams.AddNested("StartSession", err.(request.ErrInvalidParams)) } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetAbortTransaction sets the AbortTransaction field's value. func (s *SendCommandInput) SetAbortTransaction(v *AbortTransactionRequest) *SendCommandInput { s.AbortTransaction = v return s } // SetCommitTransaction sets the CommitTransaction field's value. func (s *SendCommandInput) SetCommitTransaction(v *CommitTransactionRequest) *SendCommandInput { s.CommitTransaction = v return s } // SetEndSession sets the EndSession field's value. func (s *SendCommandInput) SetEndSession(v *EndSessionRequest) *SendCommandInput { s.EndSession = v return s } // SetExecuteStatement sets the ExecuteStatement field's value. func (s *SendCommandInput) SetExecuteStatement(v *ExecuteStatementRequest) *SendCommandInput { s.ExecuteStatement = v return s } // SetFetchPage sets the FetchPage field's value. func (s *SendCommandInput) SetFetchPage(v *FetchPageRequest) *SendCommandInput { s.FetchPage = v return s } // SetSessionToken sets the SessionToken field's value. func (s *SendCommandInput) SetSessionToken(v string) *SendCommandInput { s.SessionToken = &v return s } // SetStartSession sets the StartSession field's value. func (s *SendCommandInput) SetStartSession(v *StartSessionRequest) *SendCommandInput { s.StartSession = v return s } // SetStartTransaction sets the StartTransaction field's value. func (s *SendCommandInput) SetStartTransaction(v *StartTransactionRequest) *SendCommandInput { s.StartTransaction = v return s } type SendCommandOutput struct { _ struct{} `type:"structure"` // Contains the details of the aborted transaction. AbortTransaction *AbortTransactionResult `type:"structure"` // Contains the details of the committed transaction. CommitTransaction *CommitTransactionResult `type:"structure"` // Contains the details of the ended session. EndSession *EndSessionResult `type:"structure"` // Contains the details of the executed statement. ExecuteStatement *ExecuteStatementResult `type:"structure"` // Contains the details of the fetched page. FetchPage *FetchPageResult `type:"structure"` // Contains the details of the started session that includes a session token. // This SessionToken is required for every subsequent command that is issued // during the current session. StartSession *StartSessionResult `type:"structure"` // Contains the details of the started transaction. StartTransaction *StartTransactionResult `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SendCommandOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s SendCommandOutput) GoString() string { return s.String() } // SetAbortTransaction sets the AbortTransaction field's value. func (s *SendCommandOutput) SetAbortTransaction(v *AbortTransactionResult) *SendCommandOutput { s.AbortTransaction = v return s } // SetCommitTransaction sets the CommitTransaction field's value. func (s *SendCommandOutput) SetCommitTransaction(v *CommitTransactionResult) *SendCommandOutput { s.CommitTransaction = v return s } // SetEndSession sets the EndSession field's value. func (s *SendCommandOutput) SetEndSession(v *EndSessionResult) *SendCommandOutput { s.EndSession = v return s } // SetExecuteStatement sets the ExecuteStatement field's value. func (s *SendCommandOutput) SetExecuteStatement(v *ExecuteStatementResult) *SendCommandOutput { s.ExecuteStatement = v return s } // SetFetchPage sets the FetchPage field's value. func (s *SendCommandOutput) SetFetchPage(v *FetchPageResult) *SendCommandOutput { s.FetchPage = v return s } // SetStartSession sets the StartSession field's value. func (s *SendCommandOutput) SetStartSession(v *StartSessionResult) *SendCommandOutput { s.StartSession = v return s } // SetStartTransaction sets the StartTransaction field's value. func (s *SendCommandOutput) SetStartTransaction(v *StartTransactionResult) *SendCommandOutput { s.StartTransaction = v return s } // Specifies a request to start a new session. type StartSessionRequest struct { _ struct{} `type:"structure"` // The name of the ledger to start a new session against. // // LedgerName is a required field LedgerName *string `min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartSessionRequest) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartSessionRequest) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *StartSessionRequest) Validate() error { invalidParams := request.ErrInvalidParams{Context: "StartSessionRequest"} if s.LedgerName == nil { invalidParams.Add(request.NewErrParamRequired("LedgerName")) } if s.LedgerName != nil && len(*s.LedgerName) < 1 { invalidParams.Add(request.NewErrParamMinLen("LedgerName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetLedgerName sets the LedgerName field's value. func (s *StartSessionRequest) SetLedgerName(v string) *StartSessionRequest { s.LedgerName = &v return s } // Contains the details of the started session. type StartSessionResult struct { _ struct{} `type:"structure"` // Session token of the started session. This SessionToken is required for every // subsequent command that is issued during the current session. SessionToken *string `min:"4" type:"string"` // Contains server-side performance information for the command. TimingInformation *TimingInformation `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartSessionResult) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartSessionResult) GoString() string { return s.String() } // SetSessionToken sets the SessionToken field's value. func (s *StartSessionResult) SetSessionToken(v string) *StartSessionResult { s.SessionToken = &v return s } // SetTimingInformation sets the TimingInformation field's value. func (s *StartSessionResult) SetTimingInformation(v *TimingInformation) *StartSessionResult { s.TimingInformation = v return s } // Specifies a request to start a transaction. type StartTransactionRequest struct { _ struct{} `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartTransactionRequest) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartTransactionRequest) GoString() string { return s.String() } // Contains the details of the started transaction. type StartTransactionResult struct { _ struct{} `type:"structure"` // Contains server-side performance information for the command. TimingInformation *TimingInformation `type:"structure"` // The transaction ID of the started transaction. TransactionId *string `min:"22" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartTransactionResult) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s StartTransactionResult) GoString() string { return s.String() } // SetTimingInformation sets the TimingInformation field's value. func (s *StartTransactionResult) SetTimingInformation(v *TimingInformation) *StartTransactionResult { s.TimingInformation = v return s } // SetTransactionId sets the TransactionId field's value. func (s *StartTransactionResult) SetTransactionId(v string) *StartTransactionResult { s.TransactionId = &v return s } // Contains server-side performance information for a command. Amazon QLDB captures // timing information between the times when it receives the request and when // it sends the corresponding response. type TimingInformation struct { _ struct{} `type:"structure"` // The amount of time that QLDB spent on processing the command, measured in // milliseconds. ProcessingTimeMilliseconds *int64 `type:"long"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s TimingInformation) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s TimingInformation) GoString() string { return s.String() } // SetProcessingTimeMilliseconds sets the ProcessingTimeMilliseconds field's value. func (s *TimingInformation) SetProcessingTimeMilliseconds(v int64) *TimingInformation { s.ProcessingTimeMilliseconds = &v return s } // A structure that can contain a value in multiple encoding formats. type ValueHolder struct { _ struct{} `type:"structure"` // An Amazon Ion binary value contained in a ValueHolder structure. // IonBinary is automatically base64 encoded/decoded by the SDK. IonBinary []byte `min:"1" type:"blob"` // An Amazon Ion plaintext value contained in a ValueHolder structure. IonText *string `min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ValueHolder) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ValueHolder) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ValueHolder) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ValueHolder"} if s.IonBinary != nil && len(s.IonBinary) < 1 { invalidParams.Add(request.NewErrParamMinLen("IonBinary", 1)) } if s.IonText != nil && len(*s.IonText) < 1 { invalidParams.Add(request.NewErrParamMinLen("IonText", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetIonBinary sets the IonBinary field's value. func (s *ValueHolder) SetIonBinary(v []byte) *ValueHolder { s.IonBinary = v return s } // SetIonText sets the IonText field's value. func (s *ValueHolder) SetIonText(v string) *ValueHolder { s.IonText = &v return s }