rpcservice

Feb 10, 2020

Changes in this version

+ const ErrCodeExceptionEvent

+ const ErrCodeExceptionEvent2

+ type ExceptionEvent2 struct

+ func (s *ExceptionEvent2) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error

+ func (s ExceptionEvent2) Code() string

+ func (s ExceptionEvent2) Error() string

+ func (s ExceptionEvent2) GoString() string

+ func (s ExceptionEvent2) Message() string

+ func (s ExceptionEvent2) OrigErr() error

+ func (s ExceptionEvent2) 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 RPCService

+ 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)

Jul 5, 2018

Changes in this version

+ type EmptyEventStreamEvent interface

+ type EmptyStreamEventStream struct

+ Reader EmptyStreamEventStreamReader

+ StreamCloser io.Closer

+ func (es *EmptyStreamEventStream) Close() (err error)

+ func (es *EmptyStreamEventStream) Err() error

+ func (es *EmptyStreamEventStream) Events() <-chan EmptyEventStreamEvent

+ type EmptyStreamEventStreamReader interface

+ Close func() error

+ Err func() error

+ Events func() <-chan EmptyEventStreamEvent

+ type EmptyStreamInput struct

+ func (s EmptyStreamInput) GoString() string

+ func (s EmptyStreamInput) String() string

+ type EmptyStreamOutput struct

+ EventStream *EmptyStreamEventStream

+ func (s *EmptyStreamOutput) SetEventStream(v *EmptyStreamEventStream) *EmptyStreamOutput

+ func (s *EmptyStreamOutput) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error

+ func (s EmptyStreamOutput) GoString() string

+ func (s EmptyStreamOutput) String() string

+ type PayloadOnlyStringEvent struct

+ StringPayload *string

+ 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

+ 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)

Jul 3, 2018

Changes in this version

+ const EndpointsID

+ const ServiceID

+ const ServiceName

+ type EmptyEvent struct

+ func (s *EmptyEvent) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error

+ func (s EmptyEvent) GoString() string

+ func (s EmptyEvent) String() string

+ type EventStreamEvent interface

+ type ExceptionEvent struct

+ IntVal *int64

+ Message_ *string

+ func (s *ExceptionEvent) UnmarshalEvent(payloadUnmarshaler protocol.PayloadUnmarshaler, msg eventstream.Message) error

+ func (s ExceptionEvent) Code() string

+ func (s ExceptionEvent) Error() string

+ func (s ExceptionEvent) GoString() string

+ func (s ExceptionEvent) Message() string

+ func (s ExceptionEvent) OrigErr() error

+ func (s ExceptionEvent) String() string

+ type ExplicitPayloadEvent struct

+ LongVal *int64

+ NestedVal *NestedShape

+ StringVal *string

+ 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 GetEventStreamEventStreamReader

+ StreamCloser io.Closer

+ func (es *GetEventStreamEventStream) Close() (err error)

+ func (es *GetEventStreamEventStream) Err() error

+ func (es *GetEventStreamEventStream) Events() <-chan EventStreamEvent

+ type GetEventStreamEventStreamReader interface

+ Close func() error

+ Err func() error

+ Events func() <-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

+ EventStream *GetEventStreamEventStream

+ IntVal *int64

+ StrVal *string

+ func (s *GetEventStreamOutput) SetEventStream(v *GetEventStreamEventStream) *GetEventStreamOutput

+ 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) 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) 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 PayloadOnlyBlobEvent struct

+ BlobPayload []byte

+ 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) 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 RPCService struct

+ func New(p client.ConfigProvider, cfgs ...*aws.Config) *RPCService

+ 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)