handler

Documentation

Index

• type Services
  • func NewServices(lo interfaces.Listener, keyStorage interfaces.KeyStorage, ...) *Services
  • func (c *Services) AllowMethod(method string) (m []interfaces.Method)
  • func (c *Services) CurrentStatus(ctx context.Context, req *listenerProto.MonitorRequest) (res *listenerProto.MonitorResponse, err error)
  • func (c *Services) Exchange(ctx context.Context, req *listenerProto.ExchangeRequest) (res *listenerProto.ExchangeResponse, err error)
  • func (c *Services) GetServiceDesc() []*grpc.ServiceDesc
  • func (c *Services) ListServices(ctx context.Context, req *emptypb.Empty) (res *listenerProto.ServicesResponse, err error)
  • func (c *Services) Monitor(req *listenerProto.MonitorRequest, serv listenerProto.Listener_MonitorServer) (err error)

Types

type Services

type Services struct {
	listenerProto.UnimplementedListenerServer
	listenerProto.UnimplementedEncryptionServer
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewServices

func NewServices(lo interfaces.Listener, keyStorage interfaces.KeyStorage, sessionTimeout time.Duration) *Services

func (*Services) AllowMethod

func (c *Services) AllowMethod(method string) (m []interfaces.Method)

func (*Services) CurrentStatus

func (c *Services) CurrentStatus(ctx context.Context, req *listenerProto.MonitorRequest) (res *listenerProto.MonitorResponse, err error)

CurrentStatus implement services.Listener/CurrentStatus

func (*Services) Exchange

func (c *Services) Exchange(ctx context.Context, req *listenerProto.ExchangeRequest) (res *listenerProto.ExchangeResponse, err error)

Exchange - implement for encryption services public and private key exchange

func (*Services) GetServiceDesc

func (c *Services) GetServiceDesc() []*grpc.ServiceDesc

func (*Services) ListServices

func (c *Services) ListServices(ctx context.Context, req *emptypb.Empty) (res *listenerProto.ServicesResponse, err error)

ListServices implement services.Listener/ListServices

func (*Services) Monitor

func (c *Services) Monitor(req *listenerProto.MonitorRequest, serv listenerProto.Listener_MonitorServer) (err error)

Monitor implement services.Listener/Monitor