server

Documentation

Index

• Constants
• func HandleSpoolRequest(spoolMap *MemSpoolMap, request *common.SpoolRequest, log *logging.Logger) *common.SpoolResponse
• type MemSpool
  • func NewMemSpool(publicKey *eddsa.PublicKey) *MemSpool
  • func (s *MemSpool) Append(message []byte)
  • func (s *MemSpool) Get(messageID uint32) ([]byte, bool, error)
  • func (s *MemSpool) PublicKey() *eddsa.PublicKey
  • func (s *MemSpool) Put(messageID uint32, message []byte, dirty bool)
• type MemSpoolMap
  • func NewMemSpoolMap(fileStore string, log *logging.Logger) (*MemSpoolMap, error)
  • func (m *MemSpoolMap) AppendToSpool(spoolID [common.SpoolIDSize]byte, message []byte) error
  • func (m *MemSpoolMap) CreateSpool(publicKey *eddsa.PublicKey, signature []byte) (*[common.SpoolIDSize]byte, error)
  • func (m *MemSpoolMap) PurgeSpool(spoolID [common.SpoolIDSize]byte, signature []byte) error
  • func (m *MemSpoolMap) ReadFromSpool(spoolID [common.SpoolIDSize]byte, signature []byte, messageID uint32) ([]byte, error)
  • func (m *MemSpoolMap) Shutdown()
• type SpoolEntry

Constants

const (
	SpoolStorageVersion = 0
)

Functions

func HandleSpoolRequest

func HandleSpoolRequest(spoolMap *MemSpoolMap, request *common.SpoolRequest, log *logging.Logger) *common.SpoolResponse

Types

type MemSpool

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

func NewMemSpool

func NewMemSpool(publicKey *eddsa.PublicKey) *MemSpool

func (*MemSpool) Append

func (s *MemSpool) Append(message []byte)

func (*MemSpool) Get

func (s *MemSpool) Get(messageID uint32) ([]byte, bool, error)

Get returns a message payload from the spool given a valid message ID. Second return value is the Dirty bool which is set to true if the message has not been written to disk. If returning an error then the Dirty return value is false.

func (*MemSpool) PublicKey

func (s *MemSpool) PublicKey() *eddsa.PublicKey

func (*MemSpool) Put

func (s *MemSpool) Put(messageID uint32, message []byte, dirty bool)

type MemSpoolMap

type MemSpoolMap struct {
	worker.Worker
	// contains filtered or unexported fields
}

func NewMemSpoolMap

func NewMemSpoolMap(fileStore string, log *logging.Logger) (*MemSpoolMap, error)

func (*MemSpoolMap) AppendToSpool

func (m *MemSpoolMap) AppendToSpool(spoolID [common.SpoolIDSize]byte, message []byte) error

func (*MemSpoolMap) CreateSpool

func (m *MemSpoolMap) CreateSpool(publicKey *eddsa.PublicKey, signature []byte) (*[common.SpoolIDSize]byte, error)

CreateSpool creates a new spool and returns a spool ID or an error.

func (*MemSpoolMap) PurgeSpool

func (m *MemSpoolMap) PurgeSpool(spoolID [common.SpoolIDSize]byte, signature []byte) error

PurgeSpool delete the spool associated with the given spool ID. Returns nil on success or an error.

func (*MemSpoolMap) ReadFromSpool

func (m *MemSpoolMap) ReadFromSpool(spoolID [common.SpoolIDSize]byte, signature []byte, messageID uint32) ([]byte, error)

func (*MemSpoolMap) Shutdown

func (m *MemSpoolMap) Shutdown()

type SpoolEntry

type SpoolEntry struct {
	Payload []byte
	Dirty   bool
}