system

package
v0.0.0-...-860e413 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 21, 2022 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 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 (*Server) AddInstance

func (*Server) AppName

func (s *Server) AppName() string

func (*Server) AuthMethods

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

func (*Server) ClearView

func (*Server) ExistsDomain

func (*Server) GatewayPathPrefix

func (s *Server) GatewayPathPrefix() string

func (*Server) GetInstance

func (*Server) ListDomains

func (*Server) ListViews

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL