ds

Documentation

Index

• type Attempt
• type Datastore
  • func New(logger logging.Logger, ds datastore.Datastore) Datastore
  • func NewSql(logger logging.Logger, ds datastore.Datastore) Datastore
• type Message
• type Request
• type Response
• type SqlAttempt
  • func (sql *SqlAttempt) Create(ctx context.Context, docs []*entities.Attempt) ([]string, error)
• type SqlMessage
  • func (sql *SqlMessage) Create(ctx context.Context, docs []*entities.Message) ([]string, error)
• type SqlRequest
  • func (sql *SqlRequest) Create(ctx context.Context, docs []*entities.Request) ([]string, error)
• type SqlResponse
  • func (sql *SqlResponse) Create(ctx context.Context, docs []*entities.Response) ([]string, error)

Types

type Attempt

type Attempt interface {
	Create(ctx context.Context, docs []*entities.Attempt) ([]string, error)
}

type Datastore

type Datastore interface {
	Message() Message
	Request() Request
	Response() Response
	Attempt() Attempt
}

func New

func New(logger logging.Logger, ds datastore.Datastore) Datastore

func NewSql

func NewSql(logger logging.Logger, ds datastore.Datastore) Datastore

type Message

type Message interface {
	Create(ctx context.Context, docs []*entities.Message) ([]string, error)
}

type Request

type Request interface {
	Create(ctx context.Context, docs []*entities.Request) ([]string, error)
}

type Response

type Response interface {
	Create(ctx context.Context, docs []*entities.Response) ([]string, error)
}

type SqlAttempt

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

func (*SqlAttempt) Create

func (sql *SqlAttempt) Create(ctx context.Context, docs []*entities.Attempt) ([]string, error)

type SqlMessage

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

func (*SqlMessage) Create

func (sql *SqlMessage) Create(ctx context.Context, docs []*entities.Message) ([]string, error)

type SqlRequest

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

func (*SqlRequest) Create

func (sql *SqlRequest) Create(ctx context.Context, docs []*entities.Request) ([]string, error)

type SqlResponse

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

func (*SqlResponse) Create

func (sql *SqlResponse) Create(ctx context.Context, docs []*entities.Response) ([]string, error)