appsync

package module

Go to main page

Versions in this module

v0

v0.2.0

Jun 14, 2026

Changes in this version

+ var ErrBatchPublishFailed = protocol.BatchPublishError

+ type FailedEvent struct

+ Err error

+ Payload []byte

type PublishCommandInput

+ Events [][]byte

+ type PublishCommandOutput struct

+ Errors []FailedEvent

+ Success bool

v0.1.0

Jun 7, 2026

Changes in this version

+ type Authorizers struct

+ Connect authorizer.Authorizer

+ Default authorizer.Authorizer

+ Publish authorizer.Authorizer

+ Subscribe authorizer.Authorizer

type ConnectionOptions

+ Authorizers Authorizers

type PublishCommandInput

+ Authorizer authorizer.Authorizer

type SubscribeCommandInput

+ Authorizer authorizer.Authorizer

v0.0.3

May 26, 2026

Changes in this version

+ var ErrConnectionClosed = app.ErrConnectionClosed

v0.0.2

May 16, 2026

v0.0.1

May 14, 2026

Changes in this version

+ const ProtocolEvents

+ var ErrDuplicateMessage = app.ErrDuplicateMessage

+ var ErrEmptyUrl = app.ErrEmptyUrl

+ var ErrHandshakeTimeout = app.ErrHandshakeTimeout

+ var ErrHeartbeatTimeout = app.ErrHeartbeatTimeout

+ var ErrSubscriptionClosed = app.ErrSubscriptionClosed

+ var ErrSubscriptionInboxFull = app.ErrSubscriptionInboxFull

+ var ErrSubscriptionNotFound = app.ErrSubscriptionNotFound

+ type Backpressure struct

+ ConnectionInbound uint

+ ConnectionOutbound uint

+ SubscriptionEvents uint

+ type Client interface

+ Close func(context.Context) error

+ Publish func(context.Context, PublishCommandInput) error

+ Subscribe func(context.Context, SubscribeCommandInput) (Subscription, error)

+ func Connect(ctx context.Context, options ConnectionOptions) (Client, error)

+ type ConnectionOptions struct

+ Authorizer authorizer.Authorizer

+ Backpressure Backpressure

+ Endpoint string

+ Subprotocols []string

+ type NextMessageOutput struct

+ Data []byte

+ type PublishCommandInput struct

+ Channel string

+ Payload []byte

+ type SubscribeCommandInput struct

+ Channel string

+ type Subscription interface

+ Close func(context.Context) error

+ DecodeNext func(context.Context, any) error

+ Next func(context.Context) (*NextMessageOutput, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL