server

package

v2.13.1 Latest Latest Go to latest Published: Feb 4, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Details

View Source

const (
	GrpcKeepAliveTime = 15 * time.Second
)

This section is empty.

This section is empty.

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

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

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

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

func (d *DpServer) NeedLeaderElection() bool

func (d *DpServer) Ready() bool

func (d *DpServer) SetFilter(filter Filter)

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

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