Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewGrpcServer ¶
func NewGrpcServer(cfg *GrpcServerConfig, lg *zap.Logger) error
Types ¶
type GrpcServerConfig ¶
type WatchRpcServer ¶
type WatchRpcServer struct { pb.UnimplementedWatchRPCServer // contains filtered or unexported fields }
func NewWatchRpcServer ¶
func NewWatchRpcServer(lg *zap.Logger, watcherStore *watcherStore) *WatchRpcServer
func (*WatchRpcServer) GetAppServers ¶
func (s *WatchRpcServer) GetAppServers(ctx context.Context, app *pb.App) (*pb.GetAppResponse, error)
func (*WatchRpcServer) Watch ¶
func (s *WatchRpcServer) Watch(stream pb.WatchRPC_WatchServer) error
Click to show internal directories.
Click to hide internal directories.