system

Documentation

Index

• func AddInstancePbToSetupInstance(req *system_pb.AddInstanceRequest, defaultInstance command.InstanceSetup, ...) *command.InstanceSetup
• func CurrentSequenceToPb(database string, currentSequence *query.CurrentSequence) *system_pb.View
• func CurrentSequencesToPb(database string, currentSequences *query.CurrentSequences) []*system_pb.View
• func FailedEventToPb(database string, failedEvent *query.FailedEvent) *system_pb.FailedEvent
• func FailedEventViewToPb(failedEvent *model.FailedEvent) *system_pb.FailedEvent
• func FailedEventsToPb(database string, failedEvents *query.FailedEvents) []*system_pb.FailedEvent
• func FailedEventsViewToPb(failedEvents []*model.FailedEvent) []*system_pb.FailedEvent
• func ListInstanceDomainsRequestToModel(req *system_pb.ListDomainsRequest) (*query.InstanceDomainSearchQueries, error)
• func ListInstancesRequestToModel(req *system_pb.ListInstancesRequest) (*query.InstanceSearchQueries, error)
• func RemoveFailedEventRequestToModel(req *system_pb.RemoveFailedEventRequest) *model.FailedEvent
• func ViewToPb(view *model.View) *system_pb.View
• func ViewsToPb(views []*model.View) []*system_pb.View
• type Config
• type Server
  • func CreateServer(command *command.Commands, query *query.Queries, repo repository.Repository, ...) *Server
  • func (s *Server) AddDomain(ctx context.Context, req *system_pb.AddDomainRequest) (*system_pb.AddDomainResponse, error)
  • func (s *Server) AddInstance(ctx context.Context, req *system_pb.AddInstanceRequest) (*system_pb.AddInstanceResponse, error)
  • func (s *Server) AppName() string
  • func (s *Server) AuthMethods() authz.MethodMapping
  • func (s *Server) ClearView(ctx context.Context, req *system_pb.ClearViewRequest) (*system_pb.ClearViewResponse, error)
  • func (s *Server) ExistsDomain(ctx context.Context, req *system_pb.ExistsDomainRequest) (*system_pb.ExistsDomainResponse, error)
  • func (s *Server) GatewayPathPrefix() string
  • func (s *Server) GetInstance(ctx context.Context, req *system_pb.GetInstanceRequest) (*system_pb.GetInstanceResponse, error)
  • func (s *Server) ListDomains(ctx context.Context, req *system_pb.ListDomainsRequest) (*system_pb.ListDomainsResponse, error)
  • func (s *Server) ListFailedEvents(ctx context.Context, req *system_pb.ListFailedEventsRequest) (*system_pb.ListFailedEventsResponse, error)
  • func (s *Server) ListInstances(ctx context.Context, req *system_pb.ListInstancesRequest) (*system_pb.ListInstancesResponse, error)
  • func (s *Server) ListViews(ctx context.Context, _ *system_pb.ListViewsRequest) (*system_pb.ListViewsResponse, error)
  • func (s *Server) MethodPrefix() string
  • func (s *Server) RegisterGateway() server.GatewayFunc
  • func (s *Server) RegisterServer(grpcServer *grpc.Server)
  • func (s *Server) RemoveDomain(ctx context.Context, req *system_pb.RemoveDomainRequest) (*system_pb.RemoveDomainResponse, error)
  • func (s *Server) RemoveFailedEvent(ctx context.Context, req *system_pb.RemoveFailedEventRequest) (*system_pb.RemoveFailedEventResponse, error)
  • func (s *Server) SetPrimaryDomain(ctx context.Context, req *system_pb.SetPrimaryDomainRequest) (*system_pb.SetPrimaryDomainResponse, error)
  • func (s *Server) UpdateInstance(ctx context.Context, req *system_pb.UpdateInstanceRequest) (*system_pb.UpdateInstanceResponse, error)

Functions

func AddInstancePbToSetupInstance

func AddInstancePbToSetupInstance(req *system_pb.AddInstanceRequest, defaultInstance command.InstanceSetup, externalDomain string) *command.InstanceSetup

func CurrentSequenceToPb

func CurrentSequenceToPb(database string, currentSequence *query.CurrentSequence) *system_pb.View

func CurrentSequencesToPb

func CurrentSequencesToPb(database string, currentSequences *query.CurrentSequences) []*system_pb.View

func FailedEventToPb

func FailedEventToPb(database string, failedEvent *query.FailedEvent) *system_pb.FailedEvent

func FailedEventViewToPb

func FailedEventViewToPb(failedEvent *model.FailedEvent) *system_pb.FailedEvent

func FailedEventsToPb

func FailedEventsToPb(database string, failedEvents *query.FailedEvents) []*system_pb.FailedEvent

func FailedEventsViewToPb

func FailedEventsViewToPb(failedEvents []*model.FailedEvent) []*system_pb.FailedEvent

func ListInstanceDomainsRequestToModel

func ListInstanceDomainsRequestToModel(req *system_pb.ListDomainsRequest) (*query.InstanceDomainSearchQueries, error)

func ListInstancesRequestToModel

func ListInstancesRequestToModel(req *system_pb.ListInstancesRequest) (*query.InstanceSearchQueries, error)

func RemoveFailedEventRequestToModel

func RemoveFailedEventRequestToModel(req *system_pb.RemoveFailedEventRequest) *model.FailedEvent

func ViewToPb

func ViewToPb(view *model.View) *system_pb.View

func ViewsToPb

func ViewsToPb(views []*model.View) []*system_pb.View

Types

type Config

type Config struct {
	Repository eventsourcing.Config
}

type Server

type Server struct {
	system.UnimplementedSystemServiceServer
	// contains filtered or unexported fields
}

func CreateServer

func CreateServer(
	command *command.Commands,
	query *query.Queries,
	repo repository.Repository,
	database string,
	defaultInstance command.InstanceSetup,
	externalDomain string,
) *Server

func (*Server) AddDomain

func (s *Server) AddDomain(ctx context.Context, req *system_pb.AddDomainRequest) (*system_pb.AddDomainResponse, error)

func (*Server) AddInstance

func (s *Server) AddInstance(ctx context.Context, req *system_pb.AddInstanceRequest) (*system_pb.AddInstanceResponse, error)

func (*Server) AppName

func (s *Server) AppName() string

func (*Server) AuthMethods

func (s *Server) AuthMethods() authz.MethodMapping

func (*Server) ClearView

func (s *Server) ClearView(ctx context.Context, req *system_pb.ClearViewRequest) (*system_pb.ClearViewResponse, error)

func (*Server) ExistsDomain

func (s *Server) ExistsDomain(ctx context.Context, req *system_pb.ExistsDomainRequest) (*system_pb.ExistsDomainResponse, error)

func (*Server) GatewayPathPrefix

func (s *Server) GatewayPathPrefix() string

func (*Server) GetInstance

func (s *Server) GetInstance(ctx context.Context, req *system_pb.GetInstanceRequest) (*system_pb.GetInstanceResponse, error)

func (*Server) ListDomains

func (s *Server) ListDomains(ctx context.Context, req *system_pb.ListDomainsRequest) (*system_pb.ListDomainsResponse, error)

func (*Server) ListFailedEvents

func (s *Server) ListFailedEvents(ctx context.Context, req *system_pb.ListFailedEventsRequest) (*system_pb.ListFailedEventsResponse, error)

func (*Server) ListInstances

func (s *Server) ListInstances(ctx context.Context, req *system_pb.ListInstancesRequest) (*system_pb.ListInstancesResponse, error)

func (*Server) ListViews

func (s *Server) ListViews(ctx context.Context, _ *system_pb.ListViewsRequest) (*system_pb.ListViewsResponse, error)

func (*Server) MethodPrefix

func (s *Server) MethodPrefix() string

func (*Server) RegisterGateway

func (s *Server) RegisterGateway() server.GatewayFunc

func (*Server) RegisterServer

func (s *Server) RegisterServer(grpcServer *grpc.Server)

func (*Server) RemoveDomain

func (s *Server) RemoveDomain(ctx context.Context, req *system_pb.RemoveDomainRequest) (*system_pb.RemoveDomainResponse, error)

func (*Server) RemoveFailedEvent

func (s *Server) RemoveFailedEvent(ctx context.Context, req *system_pb.RemoveFailedEventRequest) (*system_pb.RemoveFailedEventResponse, error)

func (*Server) SetPrimaryDomain

func (s *Server) SetPrimaryDomain(ctx context.Context, req *system_pb.SetPrimaryDomainRequest) (*system_pb.SetPrimaryDomainResponse, error)

func (*Server) UpdateInstance

func (s *Server) UpdateInstance(ctx context.Context, req *system_pb.UpdateInstanceRequest) (*system_pb.UpdateInstanceResponse, error)