server

Documentation

Index

• Variables
• func HTTPHandlers(proxy *gproxy.QueryProxy) ghttp.Handler
• func HealthzService(w http.ResponseWriter, _ *http.Request)
• func MustBe(method string, next http.HandlerFunc) http.HandlerFunc
• func RPCHandlers() []grpc.Handler
• func Server(port string) *http.Server
• type ErrorResponse
• type GetValueResponse
• type QueryRequest
• type QueryResponse
  • func PublishQuery(client *rpc.Client, queries ...*gdb.Query) (*QueryResponse, error)
• type QueryService
  • func (qs *QueryService) OnQuery(req *QueryRequest, resp *QueryResponse) error
• type SetValueRequest
• type SetValueResponse

Variables

var ErrNilClient = gerrors.NewGError(errors.New("nil client"))

Functions

func HTTPHandlers

func HTTPHandlers(proxy *gproxy.QueryProxy) ghttp.Handler

func HealthzService

func HealthzService(w http.ResponseWriter, _ *http.Request)

func MustBe

func MustBe(method string, next http.HandlerFunc) http.HandlerFunc

func RPCHandlers

func RPCHandlers() []grpc.Handler

func Server

func Server(port string) *http.Server

Types

type ErrorResponse

type ErrorResponse struct {
	Error string `json:"error"`
}

type GetValueResponse

type GetValueResponse struct {
	Status string `json:"status"`
	Key    string `json:"key"`
	Value  string `json:"value"`
}

type QueryRequest

type QueryRequest struct {
	Queries []*gdb.Query
	Query   *gdb.Query
}

type QueryResponse

type QueryResponse struct {
	Success bool
	Key     []byte
	Value   []byte
}

func PublishQuery

func PublishQuery(client *rpc.Client, queries ...*gdb.Query) (*QueryResponse, error)

type QueryService

type QueryService struct {
	Proxy *gproxy.QueryProxy
}

func (*QueryService) OnQuery

func (qs *QueryService) OnQuery(req *QueryRequest, resp *QueryResponse) error

type SetValueRequest

type SetValueRequest struct {
	Table string `json:"table"`
	Key   string `json:"key"`
	Value string `json:"value"`
}

type SetValueResponse

type SetValueResponse struct {
	Status string `json:"status"`
	Key    string `json:"key"`
	Value  string `json:"value"`
}