service

README

Service

Documentation

Index

• Variables
• type CheckService
  • func NewCheckService(logger log.Logger, checkUseCase *biz.CheckUsecase) *CheckService
  • func (s *CheckService) Check(ctx context.Context, req *pb.CheckRequest) (*pb.CheckResponse, error)
• type HealthService
  • func NewHealthService(backendUsecase *biz.IsBackendAvaliableUsecase) *HealthService
  • func (s *HealthService) GetLivez(ctx context.Context, req *pb.GetLivezRequest) (*pb.GetLivezResponse, error)
  • func (s *HealthService) GetReadyz(ctx context.Context, req *pb.GetReadyzRequest) (*pb.GetReadyzResponse, error)
• type LookupService
  • func NewLookupService(logger log.Logger, subjectsUseCase *biz.GetSubjectsUsecase, ...) *LookupService
  • func (s *LookupService) LookupResources(req *pb.LookupResourcesRequest, ...) error
  • func (s *LookupService) LookupSubjects(req *pb.LookupSubjectsRequest, ...) error
• type RelationshipsService
  • func NewRelationshipsService(logger log.Logger, createUseCase *biz.CreateRelationshipsUsecase, ...) *RelationshipsService
  • func (s *RelationshipsService) CreateTuples(ctx context.Context, req *pb.CreateTuplesRequest) (*pb.CreateTuplesResponse, error)
  • func (s *RelationshipsService) DeleteTuples(ctx context.Context, req *pb.DeleteTuplesRequest) (*pb.DeleteTuplesResponse, error)
  • func (s *RelationshipsService) ImportBulkTuples(...) error
  • func (s *RelationshipsService) ReadTuples(req *pb.ReadTuplesRequest, conn pb.KesselTupleService_ReadTuplesServer) error

Variables

var ProviderSet = wire.NewSet(NewRelationshipsService, NewHealthService, NewLookupService, NewCheckService)

ProviderSet is service providers.

Types

type CheckService

type CheckService struct {
	pb.UnimplementedKesselCheckServiceServer
	// contains filtered or unexported fields
}

func NewCheckService

func NewCheckService(logger log.Logger, checkUseCase *biz.CheckUsecase) *CheckService

func (*CheckService) Check

func (s *CheckService) Check(ctx context.Context, req *pb.CheckRequest) (*pb.CheckResponse, error)

type HealthService

type HealthService struct {
	pb.UnimplementedKesselRelationsHealthServiceServer
	// contains filtered or unexported fields
}

func NewHealthService

func NewHealthService(backendUsecase *biz.IsBackendAvaliableUsecase) *HealthService

func (*HealthService) GetLivez

func (s *HealthService) GetLivez(ctx context.Context, req *pb.GetLivezRequest) (*pb.GetLivezResponse, error)

func (*HealthService) GetReadyz

func (s *HealthService) GetReadyz(ctx context.Context, req *pb.GetReadyzRequest) (*pb.GetReadyzResponse, error)

type LookupService

type LookupService struct {
	pb.UnimplementedKesselLookupServiceServer
	// contains filtered or unexported fields
}

func NewLookupService

func NewLookupService(logger log.Logger, subjectsUseCase *biz.GetSubjectsUsecase, resourcesUsecase *biz.GetResourcesUsecase) *LookupService

func (*LookupService) LookupResources

func (s *LookupService) LookupResources(req *pb.LookupResourcesRequest, conn pb.KesselLookupService_LookupResourcesServer) error

func (*LookupService) LookupSubjects

func (s *LookupService) LookupSubjects(req *pb.LookupSubjectsRequest, conn pb.KesselLookupService_LookupSubjectsServer) error

type RelationshipsService

type RelationshipsService struct {
	pb.UnimplementedKesselTupleServiceServer
	// contains filtered or unexported fields
}

func NewRelationshipsService

func NewRelationshipsService(logger log.Logger, createUseCase *biz.CreateRelationshipsUsecase, readUsecase *biz.ReadRelationshipsUsecase, deleteUsecase *biz.DeleteRelationshipsUsecase, importBulkUsecase *biz.ImportBulkTuplesUsecase) *RelationshipsService

func (*RelationshipsService) CreateTuples

func (s *RelationshipsService) CreateTuples(ctx context.Context, req *pb.CreateTuplesRequest) (*pb.CreateTuplesResponse, error)

func (*RelationshipsService) DeleteTuples

func (s *RelationshipsService) DeleteTuples(ctx context.Context, req *pb.DeleteTuplesRequest) (*pb.DeleteTuplesResponse, error)

func (*RelationshipsService) ImportBulkTuples

func (s *RelationshipsService) ImportBulkTuples(stream grpc.ClientStreamingServer[pb.ImportBulkTuplesRequest, pb.ImportBulkTuplesResponse]) error

func (*RelationshipsService) ReadTuples

func (s *RelationshipsService) ReadTuples(req *pb.ReadTuplesRequest, conn pb.KesselTupleService_ReadTuplesServer) error