pg

Documentation

Index

• func MigrateDb(postgresURI string) error
• type Message
• type Storage
  • func NewStorage(postgresURI string) (*Storage, error)
  • func (s *Storage) Add(ctx context.Context, key string, ttl int64, mes datatype.SseMessage) error
  • func (s *Storage) GetMessages(ctx context.Context, keys []string, lastEventId int64) ([]datatype.SseMessage, error)

Functions

func MigrateDb

func MigrateDb(postgresURI string) error

Types

type Message

type Message []byte

type Storage

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

func NewStorage

func NewStorage(postgresURI string) (*Storage, error)

func (*Storage) Add

func (s *Storage) Add(ctx context.Context, key string, ttl int64, mes datatype.SseMessage) error

func (*Storage) GetMessages

func (s *Storage) GetMessages(ctx context.Context, keys []string, lastEventId int64) ([]datatype.SseMessage, error)