rpc

Documentation

Index

• type ArchiveRPCService
  • func NewArchiveRPCService(logger *zap.Logger, archiveInteractor usecase.ArchiveUseCase) *ArchiveRPCService
  • func (s ArchiveRPCService) CreateArchive(server archivePb.ArchiveService_CreateArchiveServer) error
  • func (s ArchiveRPCService) GetArchive(request *archivePb.GetArchiveRequest, ...) error
• type AuthenticationRPCService
  • func NewAuthenticationRPCService(logger *zap.Logger, authenticationInteractor usecase.AuthenticationUseCase, ...) AuthenticationRPCService
  • func (s AuthenticationRPCService) AuthenticateClient(ctx context.Context, request *authPb.AuthenticateRequest) (*authPb.AuthenticateResponse, error)
  • func (s AuthenticationRPCService) AuthenticateDevice(ctx context.Context, request *authPb.AuthenticateRequest) (*authPb.AuthenticateResponse, error)
• type EventRPCService
  • func NewEventRPCService(logger *zap.Logger, eventInteractor usecase.EventUseCase) *EventRPCService
  • func (s EventRPCService) PublishEvent(ctx context.Context, req *emptypb.Empty) (*eventPb.PublishEventResponse, error)
  • func (s EventRPCService) ReceiveEvent(req *emptypb.Empty, server eventPb.ArchiveEventService_ReceiveEventServer) error

Types

type ArchiveRPCService

type ArchiveRPCService struct {
	archivePb.UnimplementedArchiveServiceServer
	// contains filtered or unexported fields
}

func NewArchiveRPCService

func NewArchiveRPCService(logger *zap.Logger, archiveInteractor usecase.ArchiveUseCase) *ArchiveRPCService

func (ArchiveRPCService) CreateArchive

func (s ArchiveRPCService) CreateArchive(server archivePb.ArchiveService_CreateArchiveServer) error

func (ArchiveRPCService) GetArchive

func (s ArchiveRPCService) GetArchive(request *archivePb.GetArchiveRequest, server archivePb.ArchiveService_GetArchiveServer) error

type AuthenticationRPCService

type AuthenticationRPCService struct {
	authPb.UnimplementedAuthenticationServiceServer
	// contains filtered or unexported fields
}

func NewAuthenticationRPCService

func NewAuthenticationRPCService(
	logger *zap.Logger,
	authenticationInteractor usecase.AuthenticationUseCase,
	hmacSecret string,
) AuthenticationRPCService

func (AuthenticationRPCService) AuthenticateClient

func (s AuthenticationRPCService) AuthenticateClient(ctx context.Context, request *authPb.AuthenticateRequest) (*authPb.AuthenticateResponse, error)

func (AuthenticationRPCService) AuthenticateDevice

func (s AuthenticationRPCService) AuthenticateDevice(ctx context.Context, request *authPb.AuthenticateRequest) (*authPb.AuthenticateResponse, error)

type EventRPCService

type EventRPCService struct {
	eventPb.UnimplementedArchiveEventServiceServer
	// contains filtered or unexported fields
}

func NewEventRPCService

func NewEventRPCService(logger *zap.Logger, eventInteractor usecase.EventUseCase) *EventRPCService

func (EventRPCService) PublishEvent

func (s EventRPCService) PublishEvent(ctx context.Context, req *emptypb.Empty) (*eventPb.PublishEventResponse, error)

func (EventRPCService) ReceiveEvent

func (s EventRPCService) ReceiveEvent(req *emptypb.Empty, server eventPb.ArchiveEventService_ReceiveEventServer) error