services

Documentation

Overview

Package services provides the host services.

Index

• type Endpoint
  • func (e *Endpoint) GracefulStop(ctx context.Context) (bool, error)
  • func (e *Endpoint) Serve(ctx context.Context, serviceCtx *azservices.ServiceContext) (bool, error)
• type EndpointConfig
  • func (c *EndpointConfig) GetHostable() azservices.Hostable
  • func (c *EndpointConfig) GetPort() int
  • func (c *EndpointConfig) GetRegistration() ...
  • func (c *EndpointConfig) GetService() azservices.ServiceKind
  • func (c *EndpointConfig) GetStorageConnector() *azstorage.StorageConnector
• type Host
  • func NewHost(hostCfg *HostConfig) (*Host, error)
  • func (h *Host) GracefulStop(ctx context.Context) (bool, error)
  • func (h *Host) Serve(ctx context.Context) (bool, error)
• type HostConfig
  • func NewHostConfig(host azservices.HostKind, hostable azservices.Hostable, ...) (*HostConfig, error)
  • func (h *HostConfig) GetAppData() string
  • func (h *HostConfig) GetHostable() azservices.Hostable
  • func (h *HostConfig) GetServicesFactories() map[azservices.ServiceKind]azservices.ServiceFactoryProvider
  • func (h *HostConfig) GetStorageConnector() *azstorage.StorageConnector
• type Service
  • func (s *Service) GracefulStop(ctx context.Context) (bool, error)
  • func (s *Service) Serve(ctx context.Context) (bool, error)
• type ServiceConfig
  • func (c *ServiceConfig) GetHostable() azservices.Hostable
  • func (c *ServiceConfig) GetServiceable() azservices.Serviceable
  • func (c *ServiceConfig) GetStorageConnector() *azstorage.StorageConnector

Types

type Endpoint

type Endpoint struct {
	// contains filtered or unexported fields
}

Endpoint represents the endpoint.

func (*Endpoint) GracefulStop

func (e *Endpoint) GracefulStop(ctx context.Context) (bool, error)

GracefulStop stops the grpcendpoint.

func (*Endpoint) Serve

func (e *Endpoint) Serve(ctx context.Context, serviceCtx *azservices.ServiceContext) (bool, error)

Serve starts the grpcendpoint.

type EndpointConfig

type EndpointConfig struct {
	// contains filtered or unexported fields
}

EndpointConfig represents the endpoint configuration.

func (*EndpointConfig) GetHostable

func (c *EndpointConfig) GetHostable() azservices.Hostable

GetHostable returns the hostable.

func (*EndpointConfig) GetPort

func (c *EndpointConfig) GetPort() int

GetPort returns the port.

func (*EndpointConfig) GetRegistration

func (c *EndpointConfig) GetRegistration() func(*grpc.Server, *azservices.ServiceContext, *azservices.EndpointContext, *azstorage.StorageConnector) error

GetRegistration returns the registration function.

func (*EndpointConfig) GetService

func (c *EndpointConfig) GetService() azservices.ServiceKind

GetService returns the service kind.

func (*EndpointConfig) GetStorageConnector

func (c *EndpointConfig) GetStorageConnector() *azstorage.StorageConnector

GetStorageConnector returns the storage connector.

type Host

type Host struct {
	// contains filtered or unexported fields
}

Host represents the host.

func NewHost

func NewHost(hostCfg *HostConfig) (*Host, error)

NewHost creates a new host.

func (*Host) GracefulStop

func (h *Host) GracefulStop(ctx context.Context) (bool, error)

GracefulStop stops the host.

func (*Host) Serve

func (h *Host) Serve(ctx context.Context) (bool, error)

Serve starts the host.

type HostConfig

type HostConfig struct {
	// contains filtered or unexported fields
}

HostConfig represents the host configuration.

func NewHostConfig

func NewHostConfig(host azservices.HostKind, hostable azservices.Hostable, storageConnector *azstorage.StorageConnector,
	services []azservices.ServiceKind, servicesFactories map[azservices.ServiceKind]azservices.ServiceFactoryProvider, logger *zap.Logger, appData string,
) (*HostConfig, error)

NewHostConfig creates a new host configuration.

func (*HostConfig) GetAppData

func (h *HostConfig) GetAppData() string

GetAppData returns the app data.

func (*HostConfig) GetHostable

func (h *HostConfig) GetHostable() azservices.Hostable

GetHostable returns the hostable.

func (*HostConfig) GetServicesFactories

func (h *HostConfig) GetServicesFactories() map[azservices.ServiceKind]azservices.ServiceFactoryProvider

GetServicesFactories returns the services factories.

func (*HostConfig) GetStorageConnector

func (h *HostConfig) GetStorageConnector() *azstorage.StorageConnector

GetStorageConnector returns the storage connector.

type Service

type Service struct {
	// contains filtered or unexported fields
}

Service represents the service.

func (*Service) GracefulStop

func (s *Service) GracefulStop(ctx context.Context) (bool, error)

GracefulStop stops the service.

func (*Service) Serve

func (s *Service) Serve(ctx context.Context) (bool, error)

Serve starts the service.

type ServiceConfig

type ServiceConfig struct {
	// contains filtered or unexported fields
}

ServiceConfig represents the service configuration.

func (*ServiceConfig) GetHostable

func (c *ServiceConfig) GetHostable() azservices.Hostable

GetHostable returns the hostable.

func (*ServiceConfig) GetServiceable

func (c *ServiceConfig) GetServiceable() azservices.Serviceable

GetServiceable returns the serviceable.

func (*ServiceConfig) GetStorageConnector

func (c *ServiceConfig) GetStorageConnector() *azstorage.StorageConnector

GetStorageConnector returns the storage connector.