grpc_server

package
v0.0.0-...-2108ab1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 19, 2019 License: MIT Imports: 15 Imported by: 0

Documentation

Overview

* GRPC server configuration

Index

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 (*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 (*PublicGRPCServer) NamespaceEntityInfo

func (s *PublicGRPCServer) NamespaceEntityInfo(ctx context.Context, entity *api.NSEntity) (*api.EntityInfoResponse, error)

func (*PublicGRPCServer) RunServer

func (s *PublicGRPCServer) RunServer(srv *grpc.Server) (err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL