handlers

type Devices ¶

type Devices struct {
	messages.UnimplementedDevicesServer
	// contains filtered or unexported fields
}

func NewDevices(deviceService *service.Device, prometheusMetricsRegister metrics.PrometheusMetricsRegisterable) *Devices

func (h *Devices) GetDevices(ctx context.Context, req *messages.GetDevicesRequest) (*messages.GetDevicesResponse, error)

func (h *Devices) UpdatePrivateKey(ctx context.Context, req *messages.UpdatePrivateKeyRequest) (*messages.UpdatePrivateKeyResponse, error)

type Peers ¶

type Peers struct {
	messages.UnimplementedPeersServer
	// contains filtered or unexported fields
}

func NewPeers(
	peerService *service.Peer,
	peersRegistrationHooks []PeersRegistrationHook,
	peersDeletionHooks []PeersDeletionHook,
	prometheusMetricsRegister metrics.PrometheusMetricsRegisterable,
) *Peers

func (h *Peers) DeletePeers(ctx context.Context, req *messages.DeletePeersRequest) (*messages.DeletePeersResponse, error)

func (h *Peers) GetPeers(ctx context.Context, req *messages.GetPeersRequest) (*messages.GetPeersResponse, error)

func (h *Peers) RegisterPeers(ctx context.Context, req *messages.RegisterPeersRequest) (*messages.RegisterPeersResponse, error)

type PeersDeletionHook ¶

type PeersDeletionHook interface {
	Do(ctx context.Context, req *messages.DeletePeersRequest) error
}

PeersDeletionHook is an interface that defines the hook function to do when the peers' deletion has done successfully.

type PeersRegistrationHook ¶

type PeersRegistrationHook interface {
	Do(ctx context.Context, req *messages.RegisterPeersRequest) error
}

PeersRegistrationHook is an interface that defines the hook function to do when the peers' registration has done successfully.