Documentation ¶
Index ¶
- func GenDefaultCfg(path string) error
- type Config
- type NamingServiceServer
- func (s NamingServiceServer) CreateGroup(ctx context.Context, newGroup *pb.NewGroup) (*pb.Group, error)
- func (s NamingServiceServer) CreateUser(ctx context.Context, newUser *pb.NewUser) (*pb.User, error)
- func (s NamingServiceServer) GetAddress(ctx context.Context, userID *pb.UserId) (*pb.User, error)
- func (s NamingServiceServer) GetGroupAddresses(group *pb.Group, stream pb.NameService_GetGroupAddressesServer) error
- func (s NamingServiceServer) JoinGroup(ctx context.Context, group *pb.JoinRequest) (*pb.Group, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GenDefaultCfg ¶
Types ¶
type Config ¶
type NamingServiceServer ¶
type NamingServiceServer struct { pb.UnimplementedNameServiceServer DialTimeout time.Duration Endpoints []string }
func NewNamingService ¶
func NewNamingService(cfg *Config) *NamingServiceServer
func (NamingServiceServer) CreateGroup ¶
func (NamingServiceServer) CreateUser ¶
func (NamingServiceServer) GetAddress ¶
func (NamingServiceServer) GetGroupAddresses ¶
func (s NamingServiceServer) GetGroupAddresses(group *pb.Group, stream pb.NameService_GetGroupAddressesServer) error
func (NamingServiceServer) JoinGroup ¶
func (s NamingServiceServer) JoinGroup(ctx context.Context, group *pb.JoinRequest) (*pb.Group, error)
Click to show internal directories.
Click to hide internal directories.