Versions in this module Expand all Collapse all v1 v1.48.2 Nov 21, 2023 Changes in this version + const EndpointsID + const ErrCodeExceptionEvent + const ErrCodeExceptionEvent2 + const ServiceID + const ServiceName + type EmptyEvent struct + func (s *EmptyEvent) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *EmptyEvent) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s EmptyEvent) GoString() string + func (s EmptyEvent) String() string + type EmptyEventStreamEvent interface + type EmptyEventStreamReader interface + Close func() error + Err func() error + Events func() <-chan EmptyEventStreamEvent + type EmptyEventStreamUnknownEvent struct + Message eventstream.Message + Type string + func (e *EmptyEventStreamUnknownEvent) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (e *EmptyEventStreamUnknownEvent) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + type EmptyStreamEventStream struct + Reader EmptyEventStreamReader + func NewEmptyStreamEventStream(opts ...func(*EmptyStreamEventStream)) *EmptyStreamEventStream + func (es *EmptyStreamEventStream) Close() (err error) + func (es *EmptyStreamEventStream) Err() error + func (es *EmptyStreamEventStream) Events() <-chan EmptyEventStreamEvent + type EmptyStreamInput struct + func (s EmptyStreamInput) GoString() string + func (s EmptyStreamInput) String() string + type EmptyStreamOutput struct + func (s *EmptyStreamOutput) GetStream() *EmptyStreamEventStream + func (s *EmptyStreamOutput) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *EmptyStreamOutput) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s EmptyStreamOutput) GoString() string + func (s EmptyStreamOutput) String() string + type EventStreamEvent interface + type EventStreamReader interface + Close func() error + Err func() error + Events func() <-chan EventStreamEvent + type EventStreamUnknownEvent struct + Message eventstream.Message + Type string + func (e *EventStreamUnknownEvent) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (e *EventStreamUnknownEvent) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + type ExceptionEvent struct + IntVal *int64 + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ExceptionEvent) Code() string + func (s *ExceptionEvent) Error() string + func (s *ExceptionEvent) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *ExceptionEvent) Message() string + func (s *ExceptionEvent) OrigErr() error + func (s *ExceptionEvent) RequestID() string + func (s *ExceptionEvent) StatusCode() int + func (s *ExceptionEvent) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s ExceptionEvent) GoString() string + func (s ExceptionEvent) String() string + type ExceptionEvent2 struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ExceptionEvent2) Code() string + func (s *ExceptionEvent2) Error() string + func (s *ExceptionEvent2) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *ExceptionEvent2) Message() string + func (s *ExceptionEvent2) OrigErr() error + func (s *ExceptionEvent2) RequestID() string + func (s *ExceptionEvent2) StatusCode() int + func (s *ExceptionEvent2) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s ExceptionEvent2) GoString() string + func (s ExceptionEvent2) String() string + type ExplicitPayloadEvent struct + LongVal *int64 + NestedVal *NestedShape + StringVal *string + func (s *ExplicitPayloadEvent) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *ExplicitPayloadEvent) SetLongVal(v int64) *ExplicitPayloadEvent + func (s *ExplicitPayloadEvent) SetNestedVal(v *NestedShape) *ExplicitPayloadEvent + func (s *ExplicitPayloadEvent) SetStringVal(v string) *ExplicitPayloadEvent + func (s *ExplicitPayloadEvent) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s ExplicitPayloadEvent) GoString() string + func (s ExplicitPayloadEvent) String() string + type GetEventStreamEventStream struct + Reader EventStreamReader + func NewGetEventStreamEventStream(opts ...func(*GetEventStreamEventStream)) *GetEventStreamEventStream + func (es *GetEventStreamEventStream) Close() (err error) + func (es *GetEventStreamEventStream) Err() error + func (es *GetEventStreamEventStream) Events() <-chan EventStreamEvent + type GetEventStreamInput struct + InputVal *string + func (s *GetEventStreamInput) SetInputVal(v string) *GetEventStreamInput + func (s GetEventStreamInput) GoString() string + func (s GetEventStreamInput) String() string + type GetEventStreamOutput struct + IntVal *int64 + StrVal *string + func (s *GetEventStreamOutput) GetStream() *GetEventStreamEventStream + func (s *GetEventStreamOutput) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *GetEventStreamOutput) SetIntVal(v int64) *GetEventStreamOutput + func (s *GetEventStreamOutput) SetStrVal(v string) *GetEventStreamOutput + func (s *GetEventStreamOutput) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s GetEventStreamOutput) GoString() string + func (s GetEventStreamOutput) String() string + type HeaderOnlyEvent struct + BlobVal []byte + BoolVal *bool + ByteVal *int64 + IntegerVal *int64 + LongVal *int64 + ShortVal *int64 + StringVal *string + TimeVal *time.Time + func (s *HeaderOnlyEvent) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *HeaderOnlyEvent) SetBlobVal(v []byte) *HeaderOnlyEvent + func (s *HeaderOnlyEvent) SetBoolVal(v bool) *HeaderOnlyEvent + func (s *HeaderOnlyEvent) SetByteVal(v int64) *HeaderOnlyEvent + func (s *HeaderOnlyEvent) SetIntegerVal(v int64) *HeaderOnlyEvent + func (s *HeaderOnlyEvent) SetLongVal(v int64) *HeaderOnlyEvent + func (s *HeaderOnlyEvent) SetShortVal(v int64) *HeaderOnlyEvent + func (s *HeaderOnlyEvent) SetStringVal(v string) *HeaderOnlyEvent + func (s *HeaderOnlyEvent) SetTimeVal(v time.Time) *HeaderOnlyEvent + func (s *HeaderOnlyEvent) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s HeaderOnlyEvent) GoString() string + func (s HeaderOnlyEvent) String() string + type ImplicitPayloadEvent struct + ByteVal *int64 + IntegerVal *int64 + ShortVal *int64 + func (s *ImplicitPayloadEvent) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *ImplicitPayloadEvent) SetByteVal(v int64) *ImplicitPayloadEvent + func (s *ImplicitPayloadEvent) SetIntegerVal(v int64) *ImplicitPayloadEvent + func (s *ImplicitPayloadEvent) SetShortVal(v int64) *ImplicitPayloadEvent + func (s *ImplicitPayloadEvent) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s ImplicitPayloadEvent) GoString() string + func (s ImplicitPayloadEvent) String() string + type NestedShape struct + IntVal *int64 + StrVal *string + func (s *NestedShape) SetIntVal(v int64) *NestedShape + func (s *NestedShape) SetStrVal(v string) *NestedShape + func (s NestedShape) GoString() string + func (s NestedShape) String() string + type OtherOperationInput struct + func (s OtherOperationInput) GoString() string + func (s OtherOperationInput) String() string + type OtherOperationOutput struct + func (s OtherOperationOutput) GoString() string + func (s OtherOperationOutput) String() string + type PayloadOnlyBlobEvent struct + BlobPayload []byte + func (s *PayloadOnlyBlobEvent) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *PayloadOnlyBlobEvent) SetBlobPayload(v []byte) *PayloadOnlyBlobEvent + func (s *PayloadOnlyBlobEvent) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s PayloadOnlyBlobEvent) GoString() string + func (s PayloadOnlyBlobEvent) String() string + type PayloadOnlyEvent struct + NestedVal *NestedShape + func (s *PayloadOnlyEvent) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *PayloadOnlyEvent) SetNestedVal(v *NestedShape) *PayloadOnlyEvent + func (s *PayloadOnlyEvent) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s PayloadOnlyEvent) GoString() string + func (s PayloadOnlyEvent) String() string + type PayloadOnlyStringEvent struct + StringPayload *string + func (s *PayloadOnlyStringEvent) MarshalEvent(pm protocol.PayloadMarshaler) (msg eventstream.Message, err error) + func (s *PayloadOnlyStringEvent) SetStringPayload(v string) *PayloadOnlyStringEvent + func (s *PayloadOnlyStringEvent) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error + func (s PayloadOnlyStringEvent) GoString() string + func (s PayloadOnlyStringEvent) String() string + type RPCService struct + func New(p client.ConfigProvider, cfgs ...*aws.Config) *RPCService + func (c *RPCService) EmptyStream(input *EmptyStreamInput) (*EmptyStreamOutput, error) + func (c *RPCService) EmptyStreamRequest(input *EmptyStreamInput) (req *request.Request, output *EmptyStreamOutput) + func (c *RPCService) EmptyStreamWithContext(ctx aws.Context, input *EmptyStreamInput, opts ...request.Option) (*EmptyStreamOutput, error) + func (c *RPCService) GetEventStream(input *GetEventStreamInput) (*GetEventStreamOutput, error) + func (c *RPCService) GetEventStreamRequest(input *GetEventStreamInput) (req *request.Request, output *GetEventStreamOutput) + func (c *RPCService) GetEventStreamWithContext(ctx aws.Context, input *GetEventStreamInput, opts ...request.Option) (*GetEventStreamOutput, error) + func (c *RPCService) OtherOperation(input *OtherOperationInput) (*OtherOperationOutput, error) + func (c *RPCService) OtherOperationRequest(input *OtherOperationInput) (req *request.Request, output *OtherOperationOutput) + func (c *RPCService) OtherOperationWithContext(ctx aws.Context, input *OtherOperationInput, opts ...request.Option) (*OtherOperationOutput, error)
Go to main page