Documentation
¶
Index ¶
- func NewAppendToStream(source *tasks.CompletionSource, requireMaster bool, stream string, ...) *appendToStream
- func NewCreatePersistentSubscription(source *tasks.CompletionSource, stream string, groupName string, ...) *createPersistentSubscription
- func NewDeletePersistentSubscription(source *tasks.CompletionSource, stream string, groupName string, ...) *deletePersistentSubscription
- func NewDeleteStream(source *tasks.CompletionSource, stream string, expectedVersion int, ...) *deleteStream
- func NewReadAllEventsBackward(source *tasks.CompletionSource, pos *client.Position, max int, resolveTos bool, ...) *readAllEventsBackward
- func NewReadAllEventsForward(source *tasks.CompletionSource, pos *client.Position, max int, resolveTos bool, ...) *readAllEventsForward
- func NewReadStreamEventsBackward(source *tasks.CompletionSource, stream string, start int, max int, ...) *readStreamEventsBackward
- func NewReadStreamEventsForward(source *tasks.CompletionSource, stream string, start int, max int, ...) *readStreamEventsForward
- func NewUpdatePersistentSubscription(source *tasks.CompletionSource, stream string, groupName string, ...) *updatePersistentSubscription
- type CommitTransaction
- type CreateRequestDtoHandler
- type CreateResponseHandler
- type InspectResponseHandler
- type ReadEvent
- type StartTransaction
- type TransactionalWrite
- func (o TransactionalWrite) CreateNetworkPackage(correlationId uuid.UUID) (*client.Package, error)
- func (o TransactionalWrite) Fail(err error) error
- func (o TransactionalWrite) InspectPackage(p *client.Package) (result *client.InspectionResult, err error)
- func (o *TransactionalWrite) String() string
- type TransformResponseHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAppendToStream ¶
func NewAppendToStream( source *tasks.CompletionSource, requireMaster bool, stream string, expectedVersion int, events []*client.EventData, userCredentials *client.UserCredentials, ) *appendToStream
func NewCreatePersistentSubscription ¶
func NewCreatePersistentSubscription( source *tasks.CompletionSource, stream string, groupName string, settings *client.PersistentSubscriptionSettings, userCredentials *client.UserCredentials, ) *createPersistentSubscription
func NewDeletePersistentSubscription ¶
func NewDeletePersistentSubscription( source *tasks.CompletionSource, stream string, groupName string, userCredentials *client.UserCredentials, ) *deletePersistentSubscription
func NewDeleteStream ¶
func NewDeleteStream( source *tasks.CompletionSource, stream string, expectedVersion int, hardDelete bool, userCredentials *client.UserCredentials, ) *deleteStream
func NewReadAllEventsBackward ¶
func NewReadAllEventsBackward( source *tasks.CompletionSource, pos *client.Position, max int, resolveTos bool, userCredentials *client.UserCredentials, ) *readAllEventsBackward
func NewReadAllEventsForward ¶
func NewReadAllEventsForward( source *tasks.CompletionSource, pos *client.Position, max int, resolveTos bool, userCredentials *client.UserCredentials, ) *readAllEventsForward
func NewReadStreamEventsBackward ¶
func NewReadStreamEventsBackward( source *tasks.CompletionSource, stream string, start int, max int, resolveLinkTos bool, requireMaster bool, userCredentials *client.UserCredentials, ) *readStreamEventsBackward
func NewReadStreamEventsForward ¶
func NewReadStreamEventsForward( source *tasks.CompletionSource, stream string, start int, max int, resolveLinkTos bool, requireMaster bool, userCredentials *client.UserCredentials, ) *readStreamEventsForward
func NewUpdatePersistentSubscription ¶
func NewUpdatePersistentSubscription( source *tasks.CompletionSource, stream string, groupName string, settings *client.PersistentSubscriptionSettings, userCredentials *client.UserCredentials, ) *updatePersistentSubscription
Types ¶
type CommitTransaction ¶
type CommitTransaction struct {
// contains filtered or unexported fields
}
func NewCommitTransaction ¶
func NewCommitTransaction( source *tasks.CompletionSource, requireMaster bool, transactionId int64, userCredentials *client.UserCredentials, ) *CommitTransaction
func (CommitTransaction) CreateNetworkPackage ¶
func (CommitTransaction) InspectPackage ¶
func (o CommitTransaction) InspectPackage(p *client.Package) (result *client.InspectionResult, err error)
func (*CommitTransaction) String ¶
func (o *CommitTransaction) String() string
type CreateRequestDtoHandler ¶
type CreateResponseHandler ¶
type InspectResponseHandler ¶
type InspectResponseHandler func(message proto.Message) (*client.InspectionResult, error)
type ReadEvent ¶
type ReadEvent struct {
// contains filtered or unexported fields
}
func NewReadEvent ¶
func NewReadEvent( source *tasks.CompletionSource, stream string, eventNumber int, resolveTos bool, userCredentials *client.UserCredentials, ) *ReadEvent
func (ReadEvent) CreateNetworkPackage ¶
func (ReadEvent) InspectPackage ¶
func (o ReadEvent) InspectPackage(p *client.Package) (result *client.InspectionResult, err error)
type StartTransaction ¶
type StartTransaction struct {
// contains filtered or unexported fields
}
func NewStartTransaction ¶
func NewStartTransaction( source *tasks.CompletionSource, requireMaster bool, stream string, expectedVersion int, parentConnection client.TransactionConnection, userCredentials *client.UserCredentials, ) *StartTransaction
func (StartTransaction) CreateNetworkPackage ¶
func (StartTransaction) InspectPackage ¶
func (o StartTransaction) InspectPackage(p *client.Package) (result *client.InspectionResult, err error)
func (*StartTransaction) String ¶
func (o *StartTransaction) String() string
type TransactionalWrite ¶
type TransactionalWrite struct {
// contains filtered or unexported fields
}
func NewTransactionalWrite ¶
func NewTransactionalWrite( source *tasks.CompletionSource, requireMaster bool, transactionId int64, events []*client.EventData, userCredentials *client.UserCredentials, ) *TransactionalWrite
func (TransactionalWrite) CreateNetworkPackage ¶
func (TransactionalWrite) InspectPackage ¶
func (o TransactionalWrite) InspectPackage(p *client.Package) (result *client.InspectionResult, err error)
func (*TransactionalWrite) String ¶
func (o *TransactionalWrite) String() string
Source Files
¶
- append_to_stream.go
- commit_transaction.go
- convert_status_code.go
- create_persistent_subscription.go
- delete_persistent_subscription.go
- delete_stream.go
- logging.go
- operation.go
- read_all_events_backward.go
- read_all_events_forward.go
- read_event.go
- read_stream_events_backward.go
- read_stream_events_forward.go
- start_transaction.go
- transactional_write.go
- update_persistent_subscription.go
Click to show internal directories.
Click to hide internal directories.