operations

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
  • func NewCommitTransaction(source *tasks.CompletionSource, requireMaster bool, transactionId int64, ...) *CommitTransaction
  • func (o CommitTransaction) CreateNetworkPackage(correlationId uuid.UUID) (*client.Package, error)
  • func (o CommitTransaction) Fail(err error) error
  • func (o CommitTransaction) InspectPackage(p *client.Package) (result *client.InspectionResult, err error)
  • func (o *CommitTransaction) String() string
• type CreateRequestDtoHandler
• type CreateResponseHandler
• type InspectResponseHandler
• type ReadEvent
  • func NewReadEvent(source *tasks.CompletionSource, stream string, eventNumber int, ...) *ReadEvent
  • func (o ReadEvent) CreateNetworkPackage(correlationId uuid.UUID) (*client.Package, error)
  • func (o ReadEvent) Fail(err error) error
  • func (o ReadEvent) InspectPackage(p *client.Package) (result *client.InspectionResult, err error)
  • func (o *ReadEvent) String() string
• type StartTransaction
  • func NewStartTransaction(source *tasks.CompletionSource, requireMaster bool, stream string, ...) *StartTransaction
  • func (o StartTransaction) CreateNetworkPackage(correlationId uuid.UUID) (*client.Package, error)
  • func (o StartTransaction) Fail(err error) error
  • func (o StartTransaction) InspectPackage(p *client.Package) (result *client.InspectionResult, err error)
  • func (o *StartTransaction) String() string
• type TransactionalWrite
  • func NewTransactionalWrite(source *tasks.CompletionSource, requireMaster bool, transactionId int64, ...) *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

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 (o CommitTransaction) CreateNetworkPackage(correlationId uuid.UUID) (*client.Package, error)

func (CommitTransaction) Fail

func (o CommitTransaction) Fail(err error) error

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 CreateRequestDtoHandler func() proto.Message

type CreateResponseHandler

type CreateResponseHandler func() proto.Message

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 (o ReadEvent) CreateNetworkPackage(correlationId uuid.UUID) (*client.Package, error)

func (ReadEvent) Fail

func (o ReadEvent) Fail(err error) error

func (ReadEvent) InspectPackage

func (o ReadEvent) InspectPackage(p *client.Package) (result *client.InspectionResult, err error)

func (*ReadEvent) String

func (o *ReadEvent) String() string

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 (o StartTransaction) CreateNetworkPackage(correlationId uuid.UUID) (*client.Package, error)

func (StartTransaction) Fail

func (o StartTransaction) Fail(err error) error

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 (o TransactionalWrite) CreateNetworkPackage(correlationId uuid.UUID) (*client.Package, error)

func (TransactionalWrite) Fail

func (o TransactionalWrite) Fail(err error) error

func (TransactionalWrite) InspectPackage

func (o TransactionalWrite) InspectPackage(p *client.Package) (result *client.InspectionResult, err error)

func (*TransactionalWrite) String

func (o *TransactionalWrite) String() string

type TransformResponseHandler

type TransformResponseHandler func(message proto.Message) (interface{}, error)