server

Documentation

Overview

Package server provides the HTTP and gRPC server implementations for kvs.

Index

• func NewGRPCServer(store *kvs.Store) *grpc.Server
• func NewHTTPHandler(store *kvs.Store) http.Handler
• func Run(ctx context.Context, cfg Config, store *kvs.Store) error
• func RunListeners(ctx context.Context, httpListener, grpcListener net.Listener, store *kvs.Store) error
• type Config
  • func DefaultConfig() Config

Functions

func NewGRPCServer

func NewGRPCServer(store *kvs.Store) *grpc.Server

func NewHTTPHandler

func NewHTTPHandler(store *kvs.Store) http.Handler

func Run

func Run(ctx context.Context, cfg Config, store *kvs.Store) error

func RunListeners

func RunListeners(ctx context.Context, httpListener, grpcListener net.Listener, store *kvs.Store) error

Types

type Config

type Config struct {
	HTTPAddr string
	GRPCAddr string
}

func DefaultConfig

func DefaultConfig() Config