Versions in this module Expand all Collapse all v0 v0.3.3 Feb 19, 2026 v0.3.2 Feb 19, 2026 Changes in this version + const AlertModelVersion + const ChannelProcessingStateModelVersion + const IssueModelVersion + const MoveMappingModelVersion + type Client struct + func New(opts ...Option) *Client + func (c *Client) Close(_ context.Context) error + func (c *Client) Connect(ctx context.Context) 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) (*common.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 common.Issue, _, targetChannelID string) error + func (c *Client) SaveAlert(ctx context.Context, alert *common.Alert) error + func (c *Client) SaveChannelProcessingState(ctx context.Context, state *common.ChannelProcessingState) error + func (c *Client) SaveIssue(ctx context.Context, issue common.Issue) error + func (c *Client) SaveIssues(ctx context.Context, issues ...common.Issue) error + func (c *Client) SaveMoveMapping(ctx context.Context, moveMapping common.MoveMapping) error + type Option func(*options) + func WithAlertsTable(name string) Option + func WithAlertsTimeToLive(d time.Duration) Option + func WithChannelProcessingStateTable(name string) Option + func WithDatabase(database string) Option + func WithHost(host string) Option + func WithIssuesTable(name string) Option + func WithIssuesTimeToLive(d time.Duration) Option + func WithMoveMappingsTable(name string) Option + func WithPassword(password string) Option + func WithPoolHealthCheckPeriod(d time.Duration) Option + func WithPoolMaxConnectionIdleTime(d time.Duration) Option + func WithPoolMaxConnectionLifetime(d time.Duration) Option + func WithPoolMaxConnectionLifetimeJitter(d time.Duration) Option + func WithPoolMaxConnections(n int32) Option + func WithPoolMinConnections(n int32) Option + func WithPoolMinIdleConnections(n int32) Option + func WithPort(port int) Option + func WithSSLMode(mode SSLMode) Option + func WithTTLCleanupDisabled() Option + func WithTTLCleanupInterval(d time.Duration) Option + func WithUser(user string) Option + type SSLMode string + const SSLModeAllow + const SSLModeDisable + const SSLModePrefer + const SSLModeRequire + const SSLModeVerifyCA + const SSLModeVerifyFull
Go to main page