dynamodb

Documentation

Index

• type DynamoDBConnectionManager
  • func NewDynamoDBConnectionManager(params *DynamoDBConnectionManagerArgs) (*DynamoDBConnectionManager, error)
  • func (cm *DynamoDBConnectionManager) Get(connectionID string) (*manager.Connection, error)
  • func (cm *DynamoDBConnectionManager) Hydrate(connectionId string) error
  • func (cm *DynamoDBConnectionManager) Init(connectionId string, connectContext interface{}) error
  • func (cm *DynamoDBConnectionManager) OnConnect(newconnection *manager.Connection) error
  • func (cm *DynamoDBConnectionManager) OnDisconnect(connectionID string) error
  • func (cm *DynamoDBConnectionManager) Terminate(connectionId string) error
• type DynamoDBConnectionManagerArgs
• type DynamoDBEventManager
  • func NewDynamoDBEventManager(params *DynamoDBEventManagerArgs) (*DynamoDBEventManager, error)
  • func (cm *DynamoDBEventManager) Add(newEvent *manager.Event) error
  • func (cm *DynamoDBEventManager) Remove(eventID string) error
• type DynamoDBEventManagerArgs
• type DynamoDBSubscriptionManager
  • func NewDynamoDBSubscriptionManager(params *DynamoDBSubscriptionManagerArgs) (*DynamoDBSubscriptionManager, error)
  • func (cm *DynamoDBSubscriptionManager) ListByEvents(eventKey string, from *string) (*manager.SubscriptionResponse, error)
  • func (cm *DynamoDBSubscriptionManager) Start(subscription *manager.Subscription) error
  • func (cm *DynamoDBSubscriptionManager) Stop(connectionID string, operationID string) error
• type DynamoDBSubscriptionManagerArgs

Types

type DynamoDBConnectionManager

type DynamoDBConnectionManager struct {
	Table  string
	Client *connection.Database
	Ttl    time.Duration
}

var ConnectionManager DynamoDBConnectionManager

func NewDynamoDBConnectionManager

func NewDynamoDBConnectionManager(params *DynamoDBConnectionManagerArgs) (*DynamoDBConnectionManager, error)

func (*DynamoDBConnectionManager) Get

func (cm *DynamoDBConnectionManager) Get(connectionID string) (*manager.Connection, error)

func (*DynamoDBConnectionManager) Hydrate

func (cm *DynamoDBConnectionManager) Hydrate(connectionId string) error

func (*DynamoDBConnectionManager) Init

func (cm *DynamoDBConnectionManager) Init(connectionId string, connectContext interface{}) error

func (*DynamoDBConnectionManager) OnConnect

func (cm *DynamoDBConnectionManager) OnConnect(newconnection *manager.Connection) error

func (*DynamoDBConnectionManager) OnDisconnect

func (cm *DynamoDBConnectionManager) OnDisconnect(connectionID string) error

func (*DynamoDBConnectionManager) Terminate

func (cm *DynamoDBConnectionManager) Terminate(connectionId string) error

type DynamoDBConnectionManagerArgs

type DynamoDBConnectionManagerArgs struct {
	Table  string
	Client *dynamodb.Client
	Ttl    time.Duration
}

type DynamoDBEventManager

type DynamoDBEventManager struct {
	Table  string
	Client *event.Database
}

func NewDynamoDBEventManager

func NewDynamoDBEventManager(params *DynamoDBEventManagerArgs) (*DynamoDBEventManager, error)

func (*DynamoDBEventManager) Add

func (cm *DynamoDBEventManager) Add(newEvent *manager.Event) error

func (*DynamoDBEventManager) Remove

func (cm *DynamoDBEventManager) Remove(eventID string) error

type DynamoDBEventManagerArgs

type DynamoDBEventManagerArgs struct {
	Table  string
	Client *dynamodb.Client
}

type DynamoDBSubscriptionManager

type DynamoDBSubscriptionManager struct {
	Table             string
	Client            *subscription.Database
	IndexConnectionID string
	Ttl               time.Duration
}

var SubscriptionManager *DynamoDBSubscriptionManager

func NewDynamoDBSubscriptionManager

func NewDynamoDBSubscriptionManager(params *DynamoDBSubscriptionManagerArgs) (*DynamoDBSubscriptionManager, error)

func (*DynamoDBSubscriptionManager) ListByEvents

func (cm *DynamoDBSubscriptionManager) ListByEvents(eventKey string, from *string) (*manager.SubscriptionResponse, error)

func (*DynamoDBSubscriptionManager) Start

func (cm *DynamoDBSubscriptionManager) Start(subscription *manager.Subscription) error

func (*DynamoDBSubscriptionManager) Stop

func (cm *DynamoDBSubscriptionManager) Stop(connectionID string, operationID string) error

type DynamoDBSubscriptionManagerArgs

type DynamoDBSubscriptionManagerArgs struct {
	Table             string
	Client            *dynamodb.Client
	IndexConnectionID string
	Ttl               time.Duration
}