storage

Documentation

Index

• type Group
  • func NewGroup(storagers ...Storager) *Group
  • func (g *Group) Add(s Storager)
  • func (g *Group) Close() (err error)
  • func (g *Group) Size() int
  • func (g *Group) Write(msg *Message) (err error)
• type Marshaler
  • func JSONMarshaler(v interface{}) Marshaler
• type Message
  • func NewMessage(topic, key string, value Marshaler) *Message
• type MockStorage
  • func NewMockStorage(bufferSize int) (*MockStorage, error)
  • func (s *MockStorage) Close() error
  • func (s *MockStorage) Successes() <-chan *Message
  • func (s *MockStorage) Write(msg *Message) error
• type Storage
  • func (s *Storage) Close() error
  • func (s *Storage) Write(msg *Message) error
• type Storager
  • func New(w io.Writer) Storager
• type StringMarshaler
  • func (s StringMarshaler) Marshal() ([]byte, error)

Types

type Group

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

func NewGroup

func NewGroup(storagers ...Storager) *Group

func (*Group) Add

func (g *Group) Add(s Storager)

func (*Group) Close

func (g *Group) Close() (err error)

func (*Group) Size

func (g *Group) Size() int

func (*Group) Write

func (g *Group) Write(msg *Message) (err error)

type Marshaler

type Marshaler interface {
	Marshal() ([]byte, error)
}

func JSONMarshaler

func JSONMarshaler(v interface{}) Marshaler

type Message

type Message struct {
	Topic string
	Key   string
	Value Marshaler
}

func NewMessage

func NewMessage(topic, key string, value Marshaler) *Message

type MockStorage

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

func NewMockStorage

func NewMockStorage(bufferSize int) (*MockStorage, error)

func (*MockStorage) Close

func (s *MockStorage) Close() error

func (*MockStorage) Successes

func (s *MockStorage) Successes() <-chan *Message

func (*MockStorage) Write

func (s *MockStorage) Write(msg *Message) error

type Storage

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

func (*Storage) Close

func (s *Storage) Close() error

func (*Storage) Write

func (s *Storage) Write(msg *Message) error

type Storager

type Storager interface {
	Write(*Message) error
	Close() error
}

func New

func New(w io.Writer) Storager

type StringMarshaler

type StringMarshaler string

func (StringMarshaler) Marshal

func (s StringMarshaler) Marshal() ([]byte, error)