cqrs

Documentation

Index

• type ServiceCQRSClient
  • func (sl *ServiceCQRSClient) Add(ctx context.Context, key string, value interface{}) (err error)
  • func (sl *ServiceCQRSClient) Consume(ctx context.Context, subscriptionId string, limit int, ...) (err error)
  • func (sl *ServiceCQRSClient) DatastoreAdd(ctx context.Context, key string, value interface{}) (err error)
  • func (sl *ServiceCQRSClient) DatastoreDelete(ctx context.Context, key string) (err error)
  • func (sl *ServiceCQRSClient) DatastoreUpdate(ctx context.Context, key string, value interface{}) (err error)
  • func (sl *ServiceCQRSClient) Delete(ctx context.Context, key string) (err error)
  • func (sl *ServiceCQRSClient) Find(ctx context.Context, queryParams map[string][]string) (v interface{}, err error)
  • func (sl *ServiceCQRSClient) FindById(ctx context.Context, key string, value interface{}) (v interface{}, err error)
  • func (sl *ServiceCQRSClient) GetCloudeventDomain() string
  • func (sl *ServiceCQRSClient) IsBrokerCapable() bool
  • func (sl *ServiceCQRSClient) IsDatastoreCapable() bool
  • func (sl *ServiceCQRSClient) NewClient(ctx context.Context, cfg *ServiceCQRSConfig) (err error)
  • func (sl *ServiceCQRSClient) SetDatastoreCollection(collectionName string)
  • func (sl *ServiceCQRSClient) Update(ctx context.Context, key string, value interface{}) (err error)
• 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) SetBrokerGcpCredentialsFile(s string)
  • 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) SetDatastoreGcpCredentialsFile(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 ServiceCQRSClient

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

Service implements serviceInterface

func (*ServiceCQRSClient) Add

func (sl *ServiceCQRSClient) Add(ctx context.Context, key string, value interface{}) (err error)

func (*ServiceCQRSClient) Consume

func (sl *ServiceCQRSClient) Consume(ctx context.Context, subscriptionId string, limit int, f func(context.Context, []byte) error) (err error)

func (*ServiceCQRSClient) DatastoreAdd

func (sl *ServiceCQRSClient) DatastoreAdd(ctx context.Context, key string, value interface{}) (err error)

func (*ServiceCQRSClient) DatastoreDelete

func (sl *ServiceCQRSClient) DatastoreDelete(ctx context.Context, key string) (err error)

func (*ServiceCQRSClient) DatastoreUpdate

func (sl *ServiceCQRSClient) DatastoreUpdate(ctx context.Context, key string, value interface{}) (err error)

func (*ServiceCQRSClient) Delete

func (sl *ServiceCQRSClient) Delete(ctx context.Context, key string) (err error)

func (*ServiceCQRSClient) Find

func (sl *ServiceCQRSClient) Find(ctx context.Context, queryParams map[string][]string) (v interface{}, err error)

func (*ServiceCQRSClient) FindById

func (sl *ServiceCQRSClient) FindById(ctx context.Context, key string, value interface{}) (v interface{}, err error)

func (*ServiceCQRSClient) GetCloudeventDomain

func (sl *ServiceCQRSClient) GetCloudeventDomain() string

func (*ServiceCQRSClient) IsBrokerCapable

func (sl *ServiceCQRSClient) IsBrokerCapable() bool

func (*ServiceCQRSClient) IsDatastoreCapable

func (sl *ServiceCQRSClient) IsDatastoreCapable() bool

func (*ServiceCQRSClient) NewClient

func (sl *ServiceCQRSClient) NewClient(ctx context.Context, cfg *ServiceCQRSConfig) (err error)

func (*ServiceCQRSClient) SetDatastoreCollection

func (sl *ServiceCQRSClient) SetDatastoreCollection(collectionName string)

func (*ServiceCQRSClient) Update

func (sl *ServiceCQRSClient) Update(ctx context.Context, key string, value interface{}) (err error)

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) SetBrokerGcpCredentialsFile

func (sc *ServiceCQRSConfig) SetBrokerGcpCredentialsFile(s string)

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) SetDatastoreGcpCredentialsFile

func (sc *ServiceCQRSConfig) SetDatastoreGcpCredentialsFile(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)