store

Documentation

Index

• type InMemory
  • func NewInMemory(ti TraceID) *InMemory
  • func (ms *InMemory) Acknowledge(msg Trace) error
  • func (ms *InMemory) Result() Result
  • func (ms *InMemory) Track(msg Trace) error
  • func (ms *InMemory) Unacknowledged() ([]string, error)
• type InMemoryStoreMock
  • func (m *InMemoryStoreMock) Acknowledge(msg Trace) error
  • func (m *InMemoryStoreMock) Result() Result
  • func (m *InMemoryStoreMock) Track(msg Trace) error
  • func (m *InMemoryStoreMock) Unacknowledged() ([]string, error)
• type MsgStore
  • func New(appCfg config.Application, traceID TraceID) (MsgStore, error)
• type NoOp
  • func NewNoOp() NoOp
  • func (n NoOp) Acknowledge(msg Trace) error
  • func (n NoOp) Result() Result
  • func (n NoOp) Track(msg Trace) error
  • func (n NoOp) Unacknowledged() ([]string, error)
• type Redis
  • func NewRedis(redisaddr, namespace string, ti TraceID) (*Redis, error)
  • func (rs *Redis) Acknowledge(msg Trace) error
  • func (rs *Redis) Result() Result
  • func (rs *Redis) Track(msg Trace) error
  • func (rs *Redis) Unacknowledged() ([]string, error)
• type Result
• type Trace
• type TraceID

Types

type InMemory

type InMemory struct {
	sync.Mutex
	TraceID
	// contains filtered or unexported fields
}

func NewInMemory

func NewInMemory(ti TraceID) *InMemory

func (*InMemory) Acknowledge

func (ms *InMemory) Acknowledge(msg Trace) error

func (*InMemory) Result

func (ms *InMemory) Result() Result

func (*InMemory) Track

func (ms *InMemory) Track(msg Trace) error

func (*InMemory) Unacknowledged

func (ms *InMemory) Unacknowledged() ([]string, error)

type InMemoryStoreMock

type InMemoryStoreMock struct {
	mock.Mock
}

func (*InMemoryStoreMock) Acknowledge

func (m *InMemoryStoreMock) Acknowledge(msg Trace) error

func (*InMemoryStoreMock) Result

func (m *InMemoryStoreMock) Result() Result

func (*InMemoryStoreMock) Track

func (m *InMemoryStoreMock) Track(msg Trace) error

func (*InMemoryStoreMock) Unacknowledged

func (m *InMemoryStoreMock) Unacknowledged() ([]string, error)

type MsgStore

type MsgStore interface {
	Acknowledge(msg Trace) error
	Track(msg Trace) error
	Unacknowledged() ([]string, error)
	Result() Result
}

func New

func New(appCfg config.Application, traceID TraceID) (MsgStore, error)

type NoOp

type NoOp struct {
}

func NewNoOp

func NewNoOp() NoOp

func (NoOp) Acknowledge

func (n NoOp) Acknowledge(msg Trace) error

func (NoOp) Result

func (n NoOp) Result() Result

func (NoOp) Track

func (n NoOp) Track(msg Trace) error

func (NoOp) Unacknowledged

func (n NoOp) Unacknowledged() ([]string, error)

type Redis

type Redis struct {
	TraceID
	// contains filtered or unexported fields
}

func NewRedis

func NewRedis(redisaddr, namespace string, ti TraceID) (*Redis, error)

func (*Redis) Acknowledge

func (rs *Redis) Acknowledge(msg Trace) error

func (*Redis) Result

func (rs *Redis) Result() Result

func (*Redis) Track

func (rs *Redis) Track(msg Trace) error

func (*Redis) Unacknowledged

func (rs *Redis) Unacknowledged() ([]string, error)

type Result

type Result struct {
	Tracked      int64
	Acknowledged int64
}

type Trace

type Trace struct {
	creator.Message
	kafka.TopicPartition
}

type TraceID

type TraceID func(Trace) string