aws

Documentation

Index

• Variables
• type Store
  • func New(dynamo *dynamodb.Client, tableName string, s3 *s3.Client, bucketName string) *Store
  • func (s *Store) GetInvocation(ctx context.Context, task cid.Cid) (invocation.Invocation, error)
  • func (s *Store) GetReceipt(ctx context.Context, task cid.Cid) (receipt.AnyReceipt, error)
  • func (s *Store) Initialize(ctx context.Context) error
  • func (s *Store) Shutdown(ctx context.Context) error
  • func (s *Store) Write(ctx context.Context, message message.AgentMessage, index []agent.IndexEntry, ...) error

Variables

var DynamoAgentTableProps = struct {
	KeySchema  []types.KeySchemaElement
	Attributes []types.AttributeDefinition
}{
	KeySchema: []types.KeySchemaElement{
		{
			AttributeName: aws.String("taskkind"),
			KeyType:       types.KeyTypeHash,
		},
		{
			AttributeName: aws.String("identifier"),
			KeyType:       types.KeyTypeRange,
		},
	},
	Attributes: []types.AttributeDefinition{
		{
			AttributeName: aws.String("taskkind"),
			AttributeType: types.ScalarAttributeTypeS,
		},
		{
			AttributeName: aws.String("identifier"),
			AttributeType: types.ScalarAttributeTypeS,
		},
	},
}

Types

type Store

type Store struct {
	// contains filtered or unexported fields
}

func New

func New(dynamo *dynamodb.Client, tableName string, s3 *s3.Client, bucketName string) *Store

func (*Store) GetInvocation

func (s *Store) GetInvocation(ctx context.Context, task cid.Cid) (invocation.Invocation, error)

func (*Store) GetReceipt

func (s *Store) GetReceipt(ctx context.Context, task cid.Cid) (receipt.AnyReceipt, error)

func (*Store) Initialize

func (s *Store) Initialize(ctx context.Context) error

Initialize creates the DynamoDB table and S3 bucket if they do not already exist.

func (*Store) Shutdown

func (s *Store) Shutdown(ctx context.Context) error

func (*Store) Write

func (s *Store) Write(ctx context.Context, message message.AgentMessage, index []agent.IndexEntry, source []byte) error