server

Documentation

Index

• type DpServer
  • func NewDpServer(config dp_server.DpServerConfig, filter Filter) *DpServer
  • func (d *DpServer) GrpcServer() *grpc.Server
  • func (d *DpServer) HTTPMux() *http.ServeMux
  • func (d *DpServer) NeedLeaderElection() bool
  • func (d *DpServer) SetFilter(filter Filter)
  • func (d *DpServer) Start(stop <-chan struct{}) error
• type Filter

Types

type DpServer

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

func NewDpServer

func NewDpServer(config dp_server.DpServerConfig, filter Filter) *DpServer

func (*DpServer) GrpcServer

func (d *DpServer) GrpcServer() *grpc.Server

func (*DpServer) HTTPMux

func (d *DpServer) HTTPMux() *http.ServeMux

func (*DpServer) NeedLeaderElection

func (d *DpServer) NeedLeaderElection() bool

func (*DpServer) SetFilter

func (d *DpServer) SetFilter(filter Filter)

func (*DpServer) Start

func (d *DpServer) Start(stop <-chan struct{}) error

type Filter

type Filter func(writer http.ResponseWriter, request *http.Request) bool