service_discovery

Documentation

Index

• Constants
• Variables
• type Controller
  • func NewController(kvController kv.Controller) Controller
• type Rpc
  • func NewRPC(logger chassis.Logger, controller Controller) Rpc
• type ServiceDiscovery

Constants

const (
	ErrFailedNonce                    = "nonce failure"
	ErrFailedProcessAlreadyRegistered = "process has already be initialized"
	ErrFailedToMarshalPayload         = "failed to marshal payload"
	ErrFailedToSaveProcessDetails     = "failed to save process details"
	ErrFailedTokenForge               = "failed to forge the token"
	ErrFailedTypeCast                 = "failed to cast type"
)

const (
	// TODO: this was removed from the chassis and I'm not sure where it should go tbh
	GlobalNonceKey = "GLOBAL_NONCE"
)

Variables

var (
	ErrFailedInitialize = "failed to init the new process"
)

Types

type Controller

type Controller interface {
	ServiceDiscovery
}

func NewController

func NewController(kvController kv.Controller) Controller

type Rpc

type Rpc interface {
	chassis.RPCRegistrar
	sdConnect.ServiceDiscoveryServiceHandler
}

func NewRPC

func NewRPC(logger chassis.Logger, controller Controller) Rpc

type ServiceDiscovery

type ServiceDiscovery interface {
	Finalize(ctx context.Context, log chassis.Logger, pid string) error
	Initialize(ctx context.Context, log chassis.Logger, nonce, name string) (*sdv1.ProcessIdentity, error)
	Synchronize(ctx context.Context, log chassis.Logger, details *sdv1.ClientDetails)
}