server

Documentation

Index

• func RunGRPCServer(registerServer func(server *grpc.Server))
• func RunGRPCServerOnAddr(addr string, registerServer func(server *grpc.Server))
• func RunHTTPServer(createHandler func(router chi.Router) http.Handler)
• func RunHTTPServerOnAddr(addr string, createHandler func(router chi.Router) http.Handler)
• type PfcpConfig
  • func NewPfcpConfigure() *PfcpConfig
• type PfcpHandleFunc
• type PfcpService
  • func NewPfcpService(config *PfcpConfig, handleFunc PfcpHandleFunc) (PfcpService, error)

Functions

func RunGRPCServer

func RunGRPCServer(registerServer func(server *grpc.Server))

func RunGRPCServerOnAddr

func RunGRPCServerOnAddr(addr string, registerServer func(server *grpc.Server))

func RunHTTPServer

func RunHTTPServer(createHandler func(router chi.Router) http.Handler)

func RunHTTPServerOnAddr

func RunHTTPServerOnAddr(addr string, createHandler func(router chi.Router) http.Handler)

Types

type PfcpConfig

type PfcpConfig struct {
	// configure for common
	Mtu             int           `json:"mtu"`
	MaxFailureCount int           `json:"maxFailureCount"`
	T3              time.Duration `json:"t3"`
	N3              int           `json:"n3"`
	Heartbeat       bool          `json:"heartbeat"`
	HeartbeatPeriod time.Duration `json:"heartbeatPeriod"`
	// configure for pfcp service
	ServiceEndPoint string `json:"serviceEndPoint"`
}

var DefaultPfcpCfg PfcpConfig

func NewPfcpConfigure

func NewPfcpConfigure() *PfcpConfig

type PfcpHandleFunc

type PfcpHandleFunc func(request *pfcp.Message) (response *pfcp.Message, err error)

type PfcpService

type PfcpService interface {
	Start() error
	Close() error
}

func NewPfcpService

func NewPfcpService(config *PfcpConfig, handleFunc PfcpHandleFunc) (PfcpService, error)

NewPfcpService endPoint: ip:port, for example: :8008, 127.0.0.1:8008