Versions in this module Expand all Collapse all v0 v0.3.1 Feb 22, 2026 v0.3.0 Feb 20, 2026 Changes in this version + const BodyAttr + const GSIIsOpen + const GSIPostID + const IsOpenAttr + const IsOpenValue + const PartitionKey + const PostIDAttr + const SortKey + const TTLAttr + type API interface + BatchWriteItem func(ctx context.Context, params *dynamodb.BatchWriteItemInput, ...) (*dynamodb.BatchWriteItemOutput, error) + DeleteItem func(ctx context.Context, params *dynamodb.DeleteItemInput, ...) (*dynamodb.DeleteItemOutput, error) + DescribeTable func(ctx context.Context, params *dynamodb.DescribeTableInput, ...) (*dynamodb.DescribeTableOutput, error) + DescribeTimeToLive func(ctx context.Context, params *dynamodb.DescribeTimeToLiveInput, ...) (*dynamodb.DescribeTimeToLiveOutput, error) + GetItem func(ctx context.Context, params *dynamodb.GetItemInput, ...) (*dynamodb.GetItemOutput, error) + PutItem func(ctx context.Context, params *dynamodb.PutItemInput, ...) (*dynamodb.PutItemOutput, error) + Query func(ctx context.Context, params *dynamodb.QueryInput, ...) (*dynamodb.QueryOutput, error) + Scan func(ctx context.Context, params *dynamodb.ScanInput, ...) (*dynamodb.ScanOutput, error) + TransactWriteItems func(ctx context.Context, params *dynamodb.TransactWriteItemsInput, ...) (*dynamodb.TransactWriteItemsOutput, error) + type Client struct + func New(awsCfg *aws.Config, tableName string, opts ...Option) *Client + func (c *Client) Connect() error + func (c *Client) DeleteMoveMapping(ctx context.Context, channelID, correlationID string) error + func (c *Client) DropAllData(ctx context.Context) error + func (c *Client) FindActiveChannels(ctx context.Context) ([]string, error) + func (c *Client) FindChannelProcessingState(ctx context.Context, channelID string) (*types.ChannelProcessingState, error) + func (c *Client) FindIssueBySlackPostID(ctx context.Context, channelID, postID string) (string, json.RawMessage, error) + func (c *Client) FindMoveMapping(ctx context.Context, channelID, correlationID string) (json.RawMessage, error) + func (c *Client) FindOpenIssueByCorrelationID(ctx context.Context, channelID, correlationID string) (string, json.RawMessage, error) + func (c *Client) Init(ctx context.Context, skipSchemaValidation bool) error + func (c *Client) LoadOpenIssuesInChannel(ctx context.Context, channelID string) (map[string]json.RawMessage, error) + func (c *Client) MoveIssue(ctx context.Context, issue types.Issue, ...) error + func (c *Client) SaveAlert(ctx context.Context, alert *types.Alert) error + func (c *Client) SaveChannelProcessingState(ctx context.Context, state *types.ChannelProcessingState) error + func (c *Client) SaveIssue(ctx context.Context, issue types.Issue) error + func (c *Client) SaveIssues(ctx context.Context, issues ...types.Issue) error + func (c *Client) SaveMoveMapping(ctx context.Context, moveMapping types.MoveMapping) error + type Option func(*Options) + func WithAPI(api API) Option + func WithAlertsTimeToLive(d time.Duration) Option + func WithClock(clock func() time.Time) Option + func WithIssuesTimeToLive(d time.Duration) Option + type Options struct
Go to main page