Documentation ¶
Overview ¶
* GRPC server configuration
Index ¶
- Variables
- func RunPingWorker() (err error)
- type PrivateGRPCServer
- func (s *PrivateGRPCServer) GetFileInfo(ctx context.Context, request *api.FileInfoRequest) (response *api.FileInfoResponse, err error)
- func (s *PrivateGRPCServer) RegisterDatanode(ctx context.Context, request *api.DatanodeRegisterRequest) (*api.DatanodeRegisterResponse, error)
- func (s *PrivateGRPCServer) RunServer(srv *grpc.Server) (err error)
- func (s *PrivateGRPCServer) UnregisterDatanode(cdx context.Context, request *api.DatanodeUnregisterRequest) (*api.Response, error)
- type PublicGRPCServer
- func (s *PublicGRPCServer) ChangeNamespaceEntity(ctx context.Context, request *api.NSChangeRequest) (*api.Response, error)
- func (s *PublicGRPCServer) Init(context.Context, *api.InitRequest) (*api.Response, error)
- func (s *PublicGRPCServer) NamespaceEntityInfo(ctx context.Context, entity *api.NSEntity) (*api.EntityInfoResponse, error)
- func (s *PublicGRPCServer) RunServer(srv *grpc.Server) (err error)
Constants ¶
This section is empty.
Variables ¶
View Source
var PingInterval = time.Second * 5
View Source
var PrivateAddress = func() string { addr, passed := os.LookupEnv("PRIVATE_ADDRESS") if !passed { addr = defaultPrivateAddress } return addr }()
View Source
var PublicAddress = func() string { var err error addr, passed := os.LookupEnv("PUBLIC_ADDRESS") if !passed { addr = defaultPublicAddress } else { addr, err = utils.ProcessAddressTemplate(addr) if err != nil { log.Fatalln("Unable to retrieve public address of the node: ", err) } } return addr }()
Functions ¶
func RunPingWorker ¶
func RunPingWorker() (err error)
Types ¶
type PrivateGRPCServer ¶
type PrivateGRPCServer struct{}
func (*PrivateGRPCServer) GetFileInfo ¶
func (s *PrivateGRPCServer) GetFileInfo(ctx context.Context, request *api.FileInfoRequest) (response *api.FileInfoResponse, err error)
func (*PrivateGRPCServer) RegisterDatanode ¶
func (s *PrivateGRPCServer) RegisterDatanode(ctx context.Context, request *api.DatanodeRegisterRequest) (*api.DatanodeRegisterResponse, error)
func (*PrivateGRPCServer) RunServer ¶
func (s *PrivateGRPCServer) RunServer(srv *grpc.Server) (err error)
func (*PrivateGRPCServer) UnregisterDatanode ¶
func (s *PrivateGRPCServer) UnregisterDatanode(cdx context.Context, request *api.DatanodeUnregisterRequest) (*api.Response, error)
type PublicGRPCServer ¶
type PublicGRPCServer struct{}
PublicGRPCServer --
func (*PublicGRPCServer) ChangeNamespaceEntity ¶
func (s *PublicGRPCServer) ChangeNamespaceEntity(ctx context.Context, request *api.NSChangeRequest) (*api.Response, error)
func (*PublicGRPCServer) Init ¶
func (s *PublicGRPCServer) Init(context.Context, *api.InitRequest) (*api.Response, error)
func (*PublicGRPCServer) NamespaceEntityInfo ¶
func (s *PublicGRPCServer) NamespaceEntityInfo(ctx context.Context, entity *api.NSEntity) (*api.EntityInfoResponse, error)
Click to show internal directories.
Click to hide internal directories.