cqrs

Documentation

Index

• type ServiceCQRSBuilder
  • func (scb *ServiceCQRSBuilder) CreateSubscription(ctx context.Context, subscriptionID, topicID string, ackDeadline time.Duration) (err error)
  • func (scb *ServiceCQRSBuilder) CreateSubscriptionWithDeadLetter(ctx context.Context, subscriptionID, topicID, DLTopicID string, ...) (err error)
  • func (scb *ServiceCQRSBuilder) CreateTopic(ctx context.Context, topicID string) (err error)
  • func (scb *ServiceCQRSBuilder) DatastoreDropCollection(ctx context.Context, batchSize int) (err error)
  • func (scb *ServiceCQRSBuilder) DeleteSubscription(ctx context.Context, topicID, subscriptionID string) (err error)
  • func (scb *ServiceCQRSBuilder) DeleteTopic(ctx context.Context, topicID string) (err error)
  • func (scb *ServiceCQRSBuilder) IsBrokerCapable() bool
  • func (scb *ServiceCQRSBuilder) IsDatastoreCapable() bool
• type ServiceCQRSConfig
  • func (sc *ServiceCQRSConfig) GetBrokerConfig() *brokers.ServiceBrokerConfig
  • func (sc *ServiceCQRSConfig) GetBrokerType() brokers.ServiceBrokerType
  • func (sc *ServiceCQRSConfig) GetCloudeventDomain() string
  • func (sc *ServiceCQRSConfig) GetDatastoreConfig() *datastores.ServiceDatastoreConfig
  • func (sc *ServiceCQRSConfig) GetDatastoreType() datastores.ServiceDatastoreType
  • func (sc *ServiceCQRSConfig) GetServiceType() services.ServiceType
  • func (sc *ServiceCQRSConfig) SetBrokerTopic(s string)
  • func (sc *ServiceCQRSConfig) SetBrokerType(s string)
  • func (sc *ServiceCQRSConfig) SetCloudEventDomain(s string)
  • func (sc *ServiceCQRSConfig) SetDatastoreCollection(s string)
  • func (sc *ServiceCQRSConfig) SetDatastoreType(s string)
  • func (sc *ServiceCQRSConfig) SetGCPProjectID(s string)
  • func (sc *ServiceCQRSConfig) SetServiceType(s string)
  • func (sc *ServiceCQRSConfig) Validate() (errorString string)

Types

type ServiceCQRSBuilder

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

Service implements serviceInterface

func (*ServiceCQRSBuilder) CreateSubscription

func (scb *ServiceCQRSBuilder) CreateSubscription(ctx context.Context, subscriptionID, topicID string, ackDeadline time.Duration) (err error)

Passing a nil ackDeadline(=0) will default to 20 secs

func (*ServiceCQRSBuilder) CreateSubscriptionWithDeadLetter

func (scb *ServiceCQRSBuilder) CreateSubscriptionWithDeadLetter(ctx context.Context, subscriptionID, topicID, DLTopicID string, ackDeadline time.Duration, maxDeliveryAttempts int) (err error)

func (*ServiceCQRSBuilder) CreateTopic

func (scb *ServiceCQRSBuilder) CreateTopic(ctx context.Context, topicID string) (err error)

func (*ServiceCQRSBuilder) DatastoreDropCollection

func (scb *ServiceCQRSBuilder) DatastoreDropCollection(ctx context.Context, batchSize int) (err error)

func (*ServiceCQRSBuilder) DeleteSubscription

func (scb *ServiceCQRSBuilder) DeleteSubscription(ctx context.Context, topicID, subscriptionID string) (err error)

func (*ServiceCQRSBuilder) DeleteTopic

func (scb *ServiceCQRSBuilder) DeleteTopic(ctx context.Context, topicID string) (err error)

func (*ServiceCQRSBuilder) IsBrokerCapable

func (scb *ServiceCQRSBuilder) IsBrokerCapable() bool

func (*ServiceCQRSBuilder) IsDatastoreCapable

func (scb *ServiceCQRSBuilder) IsDatastoreCapable() bool

type ServiceCQRSConfig

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

func (*ServiceCQRSConfig) GetBrokerConfig

func (sc *ServiceCQRSConfig) GetBrokerConfig() *brokers.ServiceBrokerConfig

func (*ServiceCQRSConfig) GetBrokerType

func (sc *ServiceCQRSConfig) GetBrokerType() brokers.ServiceBrokerType

func (*ServiceCQRSConfig) GetCloudeventDomain

func (sc *ServiceCQRSConfig) GetCloudeventDomain() string

func (*ServiceCQRSConfig) GetDatastoreConfig

func (sc *ServiceCQRSConfig) GetDatastoreConfig() *datastores.ServiceDatastoreConfig

func (*ServiceCQRSConfig) GetDatastoreType

func (sc *ServiceCQRSConfig) GetDatastoreType() datastores.ServiceDatastoreType

func (*ServiceCQRSConfig) GetServiceType

func (sc *ServiceCQRSConfig) GetServiceType() services.ServiceType

func (*ServiceCQRSConfig) SetBrokerTopic

func (sc *ServiceCQRSConfig) SetBrokerTopic(s string)

func (*ServiceCQRSConfig) SetBrokerType

func (sc *ServiceCQRSConfig) SetBrokerType(s string)

func (*ServiceCQRSConfig) SetCloudEventDomain

func (sc *ServiceCQRSConfig) SetCloudEventDomain(s string)

func (*ServiceCQRSConfig) SetDatastoreCollection

func (sc *ServiceCQRSConfig) SetDatastoreCollection(s string)

func (*ServiceCQRSConfig) SetDatastoreType

func (sc *ServiceCQRSConfig) SetDatastoreType(s string)

func (*ServiceCQRSConfig) SetGCPProjectID

func (sc *ServiceCQRSConfig) SetGCPProjectID(s string)

func (*ServiceCQRSConfig) SetServiceType

func (sc *ServiceCQRSConfig) SetServiceType(s string)

func (*ServiceCQRSConfig) Validate

func (sc *ServiceCQRSConfig) Validate() (errorString string)