samples

package

v4.2.0 Latest Latest Go to latest Published: Oct 11, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/EventStore/EventStore-Client-Go

Links

Open Source Insights

Documentation ¶

Index ¶

func Abort(client *esdb.ProjectionClient)
func AbortNotFound(client *esdb.ProjectionClient)
func AppendToStream(db *esdb.Client)
func AppendToStreamOverridingUserCredentials(db *esdb.Client)
func AppendWithConcurrencyCheck(db *esdb.Client)
func AppendWithNoStream(db *esdb.Client)
func AppendWithSameId(db *esdb.Client)
func CheckpointCallbackWithInterval(db *esdb.Client)
func Create(client *esdb.ProjectionClient)
func CreateClient(connectionString string)
func CreateConflict(client *esdb.ProjectionClient)
func Delete(client *esdb.ProjectionClient)
func DeleteNotFound(client *esdb.ProjectionClient)
func Disable(client *esdb.ProjectionClient)
func DisableNotFound(client *esdb.ProjectionClient)
func Enable(client *esdb.ProjectionClient)
func EnableNotFound(client *esdb.ProjectionClient)
func EventTypePrefix(db *esdb.Client)
func EventTypeRegex(db *esdb.Client)
func ExcludeSystemEvents(db *esdb.Client)
func GetResult(client *esdb.ProjectionClient)
func GetState(client *esdb.ProjectionClient)
func GetStatus(client *esdb.ProjectionClient)
func IgnoreSystemEvents(db *esdb.Client)
func List(client *esdb.ProjectionClient)
func ListAll(client *esdb.ProjectionClient)
func ReadAllOverridingUserCredentials(db *esdb.Client)
func ReadFromAllBackwards(db *esdb.Client)
func ReadFromAllStream(db *esdb.Client)
func ReadFromStream(db *esdb.Client)
func ReadFromStreamPosition(db *esdb.Client)
func ReadFromStreamPositionCheck(db *esdb.Client)
func ReadFromStreamResolvingLinkToS(db *esdb.Client)
func ReadStreamBackwards(db *esdb.Client)
func ReadStreamOverridingUserCredentials(db *esdb.Client)
func Reset(client *esdb.ProjectionClient)
func ResetNotFound(client *esdb.ProjectionClient)
func RestartSubSystem(client *esdb.ProjectionClient)
func Run()
func StreamPrefix(db *esdb.Client)
func StreamRegex(db *esdb.Client)
func SubscribeToAll(db *esdb.Client)
func SubscribeToAllOverridingUserCredentials(db *esdb.Client)
func SubscribeToFiltered(db *esdb.Client)
func SubscribeToStream(db *esdb.Client)
func Update(client *esdb.ProjectionClient)
func UpdateNotFound(client *esdb.ProjectionClient)
func UserCertificates()
type TestEvent

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Abort ¶

func Abort(client *esdb.ProjectionClient)

func AbortNotFound ¶

func AbortNotFound(client *esdb.ProjectionClient)

func AppendToStream ¶

func AppendToStream(db *esdb.Client)

func AppendToStreamOverridingUserCredentials ¶

func AppendToStreamOverridingUserCredentials(db *esdb.Client)

func AppendWithConcurrencyCheck ¶

func AppendWithConcurrencyCheck(db *esdb.Client)

func AppendWithNoStream ¶

func AppendWithNoStream(db *esdb.Client)

func AppendWithSameId ¶

func AppendWithSameId(db *esdb.Client)

func CheckpointCallbackWithInterval ¶

func CheckpointCallbackWithInterval(db *esdb.Client)

func Create ¶

func Create(client *esdb.ProjectionClient)

func CreateClient ¶

func CreateClient(connectionString string)

func CreateConflict ¶

func CreateConflict(client *esdb.ProjectionClient)

func Delete ¶

func Delete(client *esdb.ProjectionClient)

func DeleteNotFound ¶

func DeleteNotFound(client *esdb.ProjectionClient)

func Disable ¶

func Disable(client *esdb.ProjectionClient)

func DisableNotFound ¶

func DisableNotFound(client *esdb.ProjectionClient)

func Enable ¶

func Enable(client *esdb.ProjectionClient)

func EnableNotFound ¶

func EnableNotFound(client *esdb.ProjectionClient)

func EventTypePrefix ¶

func EventTypePrefix(db *esdb.Client)

func EventTypeRegex ¶

func EventTypeRegex(db *esdb.Client)

func ExcludeSystemEvents ¶

func ExcludeSystemEvents(db *esdb.Client)

func GetResult ¶

func GetResult(client *esdb.ProjectionClient)

func GetState ¶

func GetState(client *esdb.ProjectionClient)

func GetStatus ¶

func GetStatus(client *esdb.ProjectionClient)

func IgnoreSystemEvents ¶

func IgnoreSystemEvents(db *esdb.Client)

func List ¶

func List(client *esdb.ProjectionClient)

func ListAll ¶

func ListAll(client *esdb.ProjectionClient)

func ReadAllOverridingUserCredentials ¶

func ReadAllOverridingUserCredentials(db *esdb.Client)

func ReadFromAllBackwards ¶

func ReadFromAllBackwards(db *esdb.Client)

func ReadFromAllStream ¶

func ReadFromAllStream(db *esdb.Client)

func ReadFromStream ¶

func ReadFromStream(db *esdb.Client)

func ReadFromStreamPosition ¶

func ReadFromStreamPosition(db *esdb.Client)

func ReadFromStreamPositionCheck ¶

func ReadFromStreamPositionCheck(db *esdb.Client)

func ReadFromStreamResolvingLinkToS ¶

func ReadFromStreamResolvingLinkToS(db *esdb.Client)

func ReadStreamBackwards ¶

func ReadStreamBackwards(db *esdb.Client)

func ReadStreamOverridingUserCredentials ¶

func ReadStreamOverridingUserCredentials(db *esdb.Client)

func Reset ¶

func Reset(client *esdb.ProjectionClient)

func ResetNotFound ¶

func ResetNotFound(client *esdb.ProjectionClient)

func RestartSubSystem ¶

func RestartSubSystem(client *esdb.ProjectionClient)

func Run ¶

func Run()

func StreamPrefix ¶

func StreamPrefix(db *esdb.Client)

func StreamRegex ¶

func StreamRegex(db *esdb.Client)

func SubscribeToAll ¶

func SubscribeToAll(db *esdb.Client)

func SubscribeToAllOverridingUserCredentials ¶

func SubscribeToAllOverridingUserCredentials(db *esdb.Client)

func SubscribeToFiltered ¶

func SubscribeToFiltered(db *esdb.Client)

func SubscribeToStream ¶

func SubscribeToStream(db *esdb.Client)

func Update ¶

func Update(client *esdb.ProjectionClient)

func UpdateNotFound ¶

func UpdateNotFound(client *esdb.ProjectionClient)

func UserCertificates ¶ added in v4.2.0

func UserCertificates()

Types ¶

type TestEvent ¶

type TestEvent struct {
	Id            string
	ImportantData string
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL