servers

Documentation

Index

• func GetStatus(err error) codes.Code
• type HealthServer
  • func NewHealthServer() *HealthServer
  • func (s *HealthServer) Check(ctx context.Context, in *health.HealthCheckRequest) (*health.HealthCheckResponse, error)
  • func (s *HealthServer) Watch(in *health.HealthCheckRequest, _ health.Health_WatchServer) error
• type PermissionServer
  • func NewPermissionServer(p services.IPermissionService, l logger.Interface) *PermissionServer
  • func (r *PermissionServer) Check(ctx context.Context, request *v1.CheckRequest) (*v1.CheckResponse, error)
  • func (r *PermissionServer) Expand(ctx context.Context, request *v1.ExpandRequest) (*v1.ExpandResponse, error)
  • func (r *PermissionServer) LookupQuery(ctx context.Context, request *v1.LookupQueryRequest) (*v1.LookupQueryResponse, error)
• type RelationshipServer
  • func NewRelationshipServer(r services.IRelationshipService, l logger.Interface) *RelationshipServer
  • func (r *RelationshipServer) Delete(ctx context.Context, request *v1.RelationshipDeleteRequest) (*v1.RelationshipDeleteResponse, error)
  • func (r *RelationshipServer) Read(ctx context.Context, request *v1.RelationshipReadRequest) (*v1.RelationshipReadResponse, error)
  • func (r *RelationshipServer) Write(ctx context.Context, request *v1.RelationshipWriteRequest) (*v1.RelationshipWriteResponse, error)
• type SchemaServer
  • func NewSchemaServer(m managers.IEntityConfigManager, s services.ISchemaService, l logger.Interface) *SchemaServer
  • func (r *SchemaServer) Read(ctx context.Context, request *v1.SchemaReadRequest) (*v1.SchemaReadResponse, error)
  • func (r *SchemaServer) Write(ctx context.Context, request *v1.SchemaWriteRequest) (*v1.SchemaWriteResponse, error)
• type ServiceContainer
  • func (s *ServiceContainer) Run(ctx context.Context, cfg *config.Server, authentication *config.Authn, ...) error

Functions

func GetStatus

func GetStatus(err error) codes.Code

GetStatus -

Types

type HealthServer

type HealthServer struct {
	health.UnimplementedHealthServer
}

HealthServer -

func NewHealthServer

func NewHealthServer() *HealthServer

NewHealthServer -

func (*HealthServer) Check

func (s *HealthServer) Check(ctx context.Context, in *health.HealthCheckRequest) (*health.HealthCheckResponse, error)

Check -

func (*HealthServer) Watch

func (s *HealthServer) Watch(in *health.HealthCheckRequest, _ health.Health_WatchServer) error

Watch -

type PermissionServer

type PermissionServer struct {
	v1.UnimplementedPermissionAPIServer
	// contains filtered or unexported fields
}

PermissionServer -

func NewPermissionServer

func NewPermissionServer(p services.IPermissionService, l logger.Interface) *PermissionServer

NewPermissionServer -

func (*PermissionServer) Check

func (r *PermissionServer) Check(ctx context.Context, request *v1.CheckRequest) (*v1.CheckResponse, error)

Check -

func (*PermissionServer) Expand

func (r *PermissionServer) Expand(ctx context.Context, request *v1.ExpandRequest) (*v1.ExpandResponse, error)

Expand -

func (*PermissionServer) LookupQuery

func (r *PermissionServer) LookupQuery(ctx context.Context, request *v1.LookupQueryRequest) (*v1.LookupQueryResponse, error)

LookupQuery -

type RelationshipServer

type RelationshipServer struct {
	v1.UnimplementedRelationshipAPIServer
	// contains filtered or unexported fields
}

RelationshipServer -

func NewRelationshipServer

func NewRelationshipServer(r services.IRelationshipService, l logger.Interface) *RelationshipServer

NewRelationshipServer -

func (*RelationshipServer) Delete

func (r *RelationshipServer) Delete(ctx context.Context, request *v1.RelationshipDeleteRequest) (*v1.RelationshipDeleteResponse, error)

Delete -

func (*RelationshipServer) Read

func (r *RelationshipServer) Read(ctx context.Context, request *v1.RelationshipReadRequest) (*v1.RelationshipReadResponse, error)

Read -

func (*RelationshipServer) Write

func (r *RelationshipServer) Write(ctx context.Context, request *v1.RelationshipWriteRequest) (*v1.RelationshipWriteResponse, error)

Write -

type SchemaServer

type SchemaServer struct {
	v1.UnimplementedSchemaAPIServer
	// contains filtered or unexported fields
}

SchemaServer -

func NewSchemaServer

func NewSchemaServer(m managers.IEntityConfigManager, s services.ISchemaService, l logger.Interface) *SchemaServer

NewSchemaServer -

func (*SchemaServer) Read

func (r *SchemaServer) Read(ctx context.Context, request *v1.SchemaReadRequest) (*v1.SchemaReadResponse, error)

Write -

func (*SchemaServer) Write

func (r *SchemaServer) Write(ctx context.Context, request *v1.SchemaWriteRequest) (*v1.SchemaWriteResponse, error)

Write -

type ServiceContainer

type ServiceContainer struct {
	RelationshipService services.IRelationshipService
	PermissionService   services.IPermissionService
	SchemaService       services.ISchemaService
	SchemaManager       managers.IEntityConfigManager
}

ServiceContainer -

func (*ServiceContainer) Run

func (s *ServiceContainer) Run(ctx context.Context, cfg *config.Server, authentication *config.Authn, l *logger.Logger) error

Run -