server

type Authorizer ¶ added in v0.5.2

type Authorizer interface {
	Authorize(subject, object, action string) error
}

Authorizer uses an interface to allow the service to use any authorization implementation, same as CommitLog

type CommitLog ¶ added in v0.4.1

type CommitLog interface {
	Append(*api.Record) (uint64, error)
	Read(uint64) (*api.Record, error)
}

CommitLog uses an interface to allow the service to use any log implementation that satisfies the log interface.

type Config ¶ added in v0.4.1

type Config struct {
	CommitLog  CommitLog
	Authorizer Authorizer
}

type ConsumeRequest ¶

type ConsumeRequest struct {
	Offset uint64 `json:"offset"`
}

type ConsumeResponse ¶

type ConsumeResponse struct {
	Record Record `json:"record"`
}

type Log ¶

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

func NewLog() *Log

func (c *Log) Append(record Record) (uint64, error)

func (c *Log) Read(offset uint64) (Record, error)

type ProduceRequest ¶

type ProduceRequest struct {
	Record Record `json:"record"`
}

type ProduceResponse ¶

type ProduceResponse struct {
	Offset uint64 `json:"offset"`
}

type Record ¶

type Record struct {
	Value  []byte `json:"value"`
	Offset uint64 `json:"offset"`
}