service

Documentation

Index

• func NewAggregate(ctx context.Context, resourceId string, isUserDeviceFunc isUserDeviceFunc, ...) (*aggregate, error)
• func NewAuth(jwksUrl string, tls *tls.Config) kitNetGrpc.AuthInterceptors
• type ClientCertManager
• type Config
  • func (c Config) String() string
• type EventStore
• type LogPublishErrFunc
• type RequestHandler
  • func NewRequestHandler(config Config, eventstore EventStore, publisher cqrsEventBus.Publisher, ...) *RequestHandler
  • func (r RequestHandler) ConfirmResourceDelete(ctx context.Context, request *pb.ConfirmResourceDeleteRequest) (*pb.ConfirmResourceDeleteResponse, error)
  • func (r RequestHandler) ConfirmResourceRetrieve(ctx context.Context, request *pb.ConfirmResourceRetrieveRequest) (*pb.ConfirmResourceRetrieveResponse, error)
  • func (r RequestHandler) ConfirmResourceUpdate(ctx context.Context, request *pb.ConfirmResourceUpdateRequest) (*pb.ConfirmResourceUpdateResponse, error)
  • func (r RequestHandler) DeleteResource(ctx context.Context, request *pb.DeleteResourceRequest) (*pb.DeleteResourceResponse, error)
  • func (r RequestHandler) NotifyResourceChanged(ctx context.Context, request *pb.NotifyResourceChangedRequest) (*pb.NotifyResourceChangedResponse, error)
  • func (r RequestHandler) PublishResource(ctx context.Context, request *pb.PublishResourceRequest) (*pb.PublishResourceResponse, error)
  • func (r RequestHandler) RetrieveResource(ctx context.Context, request *pb.RetrieveResourceRequest) (*pb.RetrieveResourceResponse, error)
  • func (r RequestHandler) UnpublishResource(ctx context.Context, request *pb.UnpublishResourceRequest) (*pb.UnpublishResourceResponse, error)
  • func (r RequestHandler) UpdateResource(ctx context.Context, request *pb.UpdateResourceRequest) (*pb.UpdateResourceResponse, error)
• type Server
  • func New(config Config, clientCertManager ClientCertManager, ...) *Server
  • func (s *Server) Serve() error
  • func (s *Server) Shutdown()
• type ServerCertManager

Functions

func NewAggregate

func NewAggregate(ctx context.Context, resourceId string, isUserDeviceFunc isUserDeviceFunc, SnapshotThreshold int, eventstore EventStore, retry cqrs.RetryFunc) (*aggregate, error)

NewAggregate creates new resource aggreate - it must be created for every run command.

func NewAuth

func NewAuth(jwksUrl string, tls *tls.Config) kitNetGrpc.AuthInterceptors

Types

type ClientCertManager

type ClientCertManager = interface {
	GetClientTLSConfig() *tls.Config
}

type Config

type Config struct {
	grpc.Config
	AuthServerAddr                  string         `envconfig:"AUTH_SERVER_ADDRESS" default:"127.0.0.1:9100"`
	SnapshotThreshold               int            `envconfig:"SNAPSHOT_THRESHOLD" default:"128"`
	ConcurrencyExceptionMaxRetry    int            `envconfig:"OCC_MAX_RETRY" default:"8"`
	JwksURL                         string         `envconfig:"JWKS_URL"`
	OAuth                           manager.Config `envconfig:"OAUTH"`
	UserDevicesManagerTickFrequency time.Duration  `envconfig:"USER_MGMT_TICK_FREQUENCY" default:"15s"`
	UserDevicesManagerExpiration    time.Duration  `envconfig:"USER_MGMT_EXPIRATION" default:"1m"`
}

Config represent application configuration

func (Config) String

func (c Config) String() string

String return string representation of Config

type EventStore

type EventStore interface {
	cqrsEventStore.EventStore
	cqrsMaintenance.EventStore
	GetInstanceId(ctx context.Context, resourceId string) (int64, error)
	RemoveInstanceId(ctx context.Context, instanceId int64) error
}

type LogPublishErrFunc

type LogPublishErrFunc func(err error)

type RequestHandler

type RequestHandler struct {
	// contains filtered or unexported fields
}

RequestHandler for handling incoming request

func NewRequestHandler

func NewRequestHandler(config Config, eventstore EventStore, publisher cqrsEventBus.Publisher, isUserDeviceFunc isUserDeviceFunc) *RequestHandler

NewRequestHandler factory for new RequestHandler

func (RequestHandler) ConfirmResourceDelete

func (r RequestHandler) ConfirmResourceDelete(ctx context.Context, request *pb.ConfirmResourceDeleteRequest) (*pb.ConfirmResourceDeleteResponse, error)

func (RequestHandler) ConfirmResourceRetrieve

func (r RequestHandler) ConfirmResourceRetrieve(ctx context.Context, request *pb.ConfirmResourceRetrieveRequest) (*pb.ConfirmResourceRetrieveResponse, error)

func (RequestHandler) ConfirmResourceUpdate

func (r RequestHandler) ConfirmResourceUpdate(ctx context.Context, request *pb.ConfirmResourceUpdateRequest) (*pb.ConfirmResourceUpdateResponse, error)

func (RequestHandler) DeleteResource

func (r RequestHandler) DeleteResource(ctx context.Context, request *pb.DeleteResourceRequest) (*pb.DeleteResourceResponse, error)

func (RequestHandler) NotifyResourceChanged

func (r RequestHandler) NotifyResourceChanged(ctx context.Context, request *pb.NotifyResourceChangedRequest) (*pb.NotifyResourceChangedResponse, error)

func (RequestHandler) PublishResource

func (r RequestHandler) PublishResource(ctx context.Context, request *pb.PublishResourceRequest) (*pb.PublishResourceResponse, error)

func (RequestHandler) RetrieveResource

func (r RequestHandler) RetrieveResource(ctx context.Context, request *pb.RetrieveResourceRequest) (*pb.RetrieveResourceResponse, error)

func (RequestHandler) UnpublishResource

func (r RequestHandler) UnpublishResource(ctx context.Context, request *pb.UnpublishResourceRequest) (*pb.UnpublishResourceResponse, error)

func (RequestHandler) UpdateResource

func (r RequestHandler) UpdateResource(ctx context.Context, request *pb.UpdateResourceRequest) (*pb.UpdateResourceResponse, error)

type Server

type Server struct {
	// contains filtered or unexported fields
}

Server handle HTTP request

func New

func New(config Config, clientCertManager ClientCertManager, serverCertManager ServerCertManager, eventStore EventStore, publisher cqrsEventBus.Publisher) *Server

New creates new Server with provided store and publisher.

func (*Server) Serve

func (s *Server) Serve() error

Serve serve starts the service's HTTP server and blocks.

func (*Server) Shutdown

func (s *Server) Shutdown()

Shutdown ends serving

type ServerCertManager

type ServerCertManager = interface {
	GetServerTLSConfig() *tls.Config
}