Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DownloadServer ¶
DownloadServer is a structure that holds the download server.
func NewServer ¶
func NewServer(logger *logrus.Logger) *DownloadServer
NewServer configures and creates a grpc.Server instance with the download service health check service. Configure using environment variables. `HEALTH_CHECK_INTERVAL`: Interval to update serving state of the health check server. `S3_ACCESS_KEY`: S3 accress key to connect with s3 backend. `S3_SECRET_KEY`: S3 secret key to connect with s3 backend. `S3_ENDPOINT`: S3 endpoint of s3 backend to connect to. `S3_TOKEN`: S3 token of s3 backend to connect to. `S3_REGION`: S3 ergion of s3 backend to connect to. `S3_SSL`: Enable or Disable SSL on S3 connection. `TCP_PORT`: TCP port on which the grpc server would serve on.
func (*DownloadServer) GetService ¶
func (s *DownloadServer) GetService() download.Service
GetService returns a copy of the underlying download service.
func (DownloadServer) Serve ¶
func (s DownloadServer) Serve(lis net.Listener)
Serve accepts incoming connections on the listener `lis`, creating a new ServerTransport and service goroutine for each. The service goroutines read gRPC requests and then call the registered handlers to reply to them. Serve returns when `lis.Accept` fails with fatal errors. `lis` will be closed when this method returns. If `lis` is nil then Serve creates a `net.Listener` with "tcp" network listening on the configured `TCP_PORT`, which defaults to "8080". Serve will return a non-nil error unless Stop or GracefulStop is called.
Source Files