storage

Documentation

Index

• Variables
• func NewRouter() *mux.Router
• type Handler
  • func NewHandler(store *raft.KVStore) *Handler
  • func (h *Handler) AuditLog(ctx context.Context, request *proto.AuditLogRequest, ...) error
  • func (h *Handler) Create(ctx context.Context, request *proto.CreateRequest, ...) error
  • func (h *Handler) Delete(ctx context.Context, request *proto.DeleteRequest, ...) error
  • func (h *Handler) Lookup(ctx context.Context, request *storage.LookupRequest, ...) error
  • func (h *Handler) Propose(ctx context.Context, request *storage.ProposeRequest, ...) error
  • func (h *Handler) Read(ctx context.Context, request *proto.ReadRequest, response *proto.ReadResponse) error
  • func (h *Handler) Search(ctx context.Context, request *proto.SearchRequest, ...) error
  • func (h *Handler) Update(ctx context.Context, request *proto.UpdateRequest, ...) error
  • func (h *Handler) Watch(ctx context.Context, request *proto.WatchRequest, ...) error

Variables

var (
	NotImplemented = errors.New("service not implemented")
	NotFound       = errors.New("not found")
)

Functions

func NewRouter

func NewRouter() *mux.Router

NewRouter creates and configures a new mux router to serve the config storage.

Types

type Handler

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

func NewHandler

func NewHandler(store *raft.KVStore) *Handler

func (*Handler) AuditLog

func (h *Handler) AuditLog(ctx context.Context, request *proto.AuditLogRequest, response *proto.AuditLogResponse) error

func (*Handler) Create

func (h *Handler) Create(ctx context.Context, request *proto.CreateRequest, response *proto.CreateResponse) error

func (*Handler) Delete

func (h *Handler) Delete(ctx context.Context, request *proto.DeleteRequest, response *proto.DeleteResponse) error

func (*Handler) Lookup

func (h *Handler) Lookup(ctx context.Context, request *storage.LookupRequest, resp *storage.LookupResponse) error

func (*Handler) Propose

func (h *Handler) Propose(ctx context.Context, request *storage.ProposeRequest, resp *storage.ProposeResponse) error

func (*Handler) Read

func (h *Handler) Read(ctx context.Context, request *proto.ReadRequest, response *proto.ReadResponse) error

func (*Handler) Search

func (h *Handler) Search(ctx context.Context, request *proto.SearchRequest, response *proto.SearchResponse) error

func (*Handler) Update

func (h *Handler) Update(ctx context.Context, request *proto.UpdateRequest, response *proto.UpdateResponse) error

func (*Handler) Watch

func (h *Handler) Watch(ctx context.Context, request *proto.WatchRequest, stream proto.Config_WatchStream) error