storage

Documentation

Index

• Variables
• type MessageRepository
  • func NewMessageRepository(server *etcdserver.EtcdServer) *MessageRepository
  • func (s *MessageRepository) Save(msg *server.Message, stream *server.Stream, lease lease.LeaseID) (int64, error)
• type StreamRepository
  • func NewStreamRepository(server *etcdserver.EtcdServer) *StreamRepository
  • func (s *StreamRepository) Find(subject string) []*server.Stream
  • func (s *StreamRepository) Save(stream *server.Stream) (string, error)
  • func (s *StreamRepository) Watch(subject string) (<-chan *server.Message, chan<- bool)

Variables

var (
	Space = uuid.NewSHA1(uuid.NameSpaceURL, url)
)

Types

type MessageRepository

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

func NewMessageRepository

func NewMessageRepository(server *etcdserver.EtcdServer) *MessageRepository

func (*MessageRepository) Save

func (s *MessageRepository) Save(msg *server.Message, stream *server.Stream, lease lease.LeaseID) (int64, error)

type StreamRepository

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

func NewStreamRepository

func NewStreamRepository(server *etcdserver.EtcdServer) *StreamRepository

func (*StreamRepository) Find

func (s *StreamRepository) Find(subject string) []*server.Stream

func (*StreamRepository) Save

func (s *StreamRepository) Save(stream *server.Stream) (string, error)

func (*StreamRepository) Watch

func (s *StreamRepository) Watch(subject string) (<-chan *server.Message, chan<- bool)