server

Documentation

Index

• type CascadeLower
• type CascadeServer
  • func NewCascadeServer(svcCtx *svc.CascadeContext) *CascadeServer
  • func (s *CascadeServer) HeartBeat(ctx context.Context, in *cascade.ReqHeartBeat) (*cascade.RespHeartBeat, error)
  • func (s *CascadeServer) LowerCreate(ctx context.Context, in *cascade.ReqLowerCreate) (*cascade.RespLowerCreate, error)
  • func (s *CascadeServer) LowerDel(ctx context.Context, in *cascade.ReqLowerDel) (*cascade.RespLowerDel, error)
  • func (s *CascadeServer) LowerGetInfo(ctx context.Context, in *cascade.ReqLowerGetInfo) (*cascade.RespLowerGetInfo, error)
  • func (s *CascadeServer) LowerSearch(ctx context.Context, in *cascade.ReqLowerSearch) (*cascade.RespLowerSearch, error)
  • func (s *CascadeServer) LowerUpdate(ctx context.Context, in *cascade.ReqLowerUpdate) (*cascade.RespLowerUpdate, error)
  • func (s *CascadeServer) RegisterServer(server *zrpc.Server)
  • func (s *CascadeServer) SuperiorGet(ctx context.Context, in *cascade.ReqSuperiorGet) (*cascade.RespSuperiorGet, error)
  • func (s *CascadeServer) SuperiorSet(ctx context.Context, in *cascade.ReqSuperiorSet) (*cascade.RespSuperiorSet, error)
  • func (s *CascadeServer) SyncTime(ctx context.Context, in *cascade.ReqSyncTime) (*cascade.RespSyncTime, error)
• type GateWayConfig
• type Gateway
• type HttBaseAuthRequest

Types

type CascadeLower

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

type CascadeServer

type CascadeServer struct {
	cascade.UnimplementedCascadeClientServer
	// contains filtered or unexported fields
}

func NewCascadeServer

func NewCascadeServer(svcCtx *svc.CascadeContext) *CascadeServer

func (*CascadeServer) HeartBeat

func (s *CascadeServer) HeartBeat(ctx context.Context, in *cascade.ReqHeartBeat) (*cascade.RespHeartBeat, error)

func (*CascadeServer) LowerCreate

func (s *CascadeServer) LowerCreate(ctx context.Context, in *cascade.ReqLowerCreate) (*cascade.RespLowerCreate, error)

func (*CascadeServer) LowerDel

func (s *CascadeServer) LowerDel(ctx context.Context, in *cascade.ReqLowerDel) (*cascade.RespLowerDel, error)

func (*CascadeServer) LowerGetInfo

func (s *CascadeServer) LowerGetInfo(ctx context.Context, in *cascade.ReqLowerGetInfo) (*cascade.RespLowerGetInfo, error)

func (*CascadeServer) LowerSearch

func (s *CascadeServer) LowerSearch(ctx context.Context, in *cascade.ReqLowerSearch) (*cascade.RespLowerSearch, error)

func (*CascadeServer) LowerUpdate

func (s *CascadeServer) LowerUpdate(ctx context.Context, in *cascade.ReqLowerUpdate) (*cascade.RespLowerUpdate, error)

func (*CascadeServer) RegisterServer

func (s *CascadeServer) RegisterServer(server *zrpc.Server)

func (*CascadeServer) SuperiorGet

func (s *CascadeServer) SuperiorGet(ctx context.Context, in *cascade.ReqSuperiorGet) (*cascade.RespSuperiorGet, error)

func (*CascadeServer) SuperiorSet

func (s *CascadeServer) SuperiorSet(ctx context.Context, in *cascade.ReqSuperiorSet) (*cascade.RespSuperiorSet, error)

func (*CascadeServer) SyncTime

func (s *CascadeServer) SyncTime(ctx context.Context, in *cascade.ReqSyncTime) (*cascade.RespSyncTime, error)

type GateWayConfig

type GateWayConfig struct {
	Enabled           map[string]struct{}
	SyncTimeEnable    int
	OutboundAddr      string
	NetroutetoolPort  int
	SipRegsvrAddr     string
	CacheExpireSecs   int
	HeartBeatInterval int
}

type Gateway

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

type HttBaseAuthRequest

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