storage

package
v2.3.3+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 9, 2021 License: AGPL-3.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL