spanner

Documentation

Index

• Constants
• Variables
• type Repo
  • func NewRepo(ctx context.Context, cfg config.Spanner) (Repo, error)
  • func (r Repo) Close()
  • func (w Repo) DeleteWebhook(ctx context.Context, cirlceId string) (time.Time, error)
  • func (d Repo) GetDummy(ctx context.Context, dummyID string) (model.Dummy, error)
  • func (w Repo) GetWebhookByCircleId(ctx context.Context, cirlceId string) (model.Webhook, error)
  • func (r Repo) TxManager() repository.TxManager
  • func (w Repo) UpsertWebhook(ctx context.Context, webhook model.Webhook) error

Constants

const (
	TableDummies  = "Dummies"
	TableWebhooks = "Webhooks"
)

Variables

var DBErrNotFound = errs.Errorf(errs.CodeDBNotFound)

Types

type Repo

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

func NewRepo

func NewRepo(ctx context.Context, cfg config.Spanner) (Repo, error)

func (Repo) Close

func (r Repo) Close()

func (Repo) DeleteWebhook

func (w Repo) DeleteWebhook(ctx context.Context, cirlceId string) (time.Time, error)

func (Repo) GetDummy

func (d Repo) GetDummy(ctx context.Context, dummyID string) (model.Dummy, error)

func (Repo) GetWebhookByCircleId

func (w Repo) GetWebhookByCircleId(ctx context.Context, cirlceId string) (model.Webhook, error)

func (Repo) TxManager

func (r Repo) TxManager() repository.TxManager

func (Repo) UpsertWebhook

func (w Repo) UpsertWebhook(ctx context.Context, webhook model.Webhook) error