goes

type Command byte

type Configuration struct {
	Address             string
	Port                int
	Login               string
	Password            string
	ReconnectionDelay   int
	MaxReconnects       int
	MaxOperationRetries int
	EndpointDiscoverer  EndpointDiscoverer
}

type EndpointDiscoverer interface {
	Discover() (MemberInfo, error)
}

type Event struct {
	EventID   uuid.UUID
	EventType string
	IsJSON    bool
	Data      []byte
	Metadata  []byte
}

type EventStoreConnection struct {
	Config *Configuration
	Socket *net.TCPConn

	ConnectionID uuid.UUID
	Mutex        *sync.Mutex
	// contains filtered or unexported fields
}

type GossipEndpointDiscoverer struct {
	MaxDiscoverAttempts int
	GossipSeeds         []string
}

type GossipResponse struct {
	Members []MemberInfo `json:"members"`
}

type GossipSeed struct {
	ExternalTCPIP    string
	ExternalHTTPPort int
}

type MemberInfo struct {
	State            string `json:"state"`
	IsAlive          bool   `json:"isAlive"`
	ExternalTCPIP    string `json:"externalTcpIp"`
	ExternalHTTPPort int    `json:"externalHttpPort"`
	ExternalTCPPort  int    `json:"externalTcpPort"`
}

type PersistentSubscriptionSettings struct {
	ResolveLinkTos             bool
	StartFrom                  int
	MessageTimeoutMilliseconds int
	RecordStatistics           bool
	LiveBufferSize             int
	ReadBatchSize              int
	BufferSize                 int
	MaxRetryCount              int
	PreferRoundRobit           bool
	CheckpointAfterTime        int
	CheckpointMaxCount         int
	CheckpointMinCount         int
	SubscriberMaxCount         int
	NamedConsumerStrategy      string
}

type Subscription struct {
	CorrelationID uuid.UUID
	Connection    *EventStoreConnection
	Channel       chan TCPPackage
	EventAppeared eventAppeared
	Dropped       dropped
	Started       bool
}

type TCPPackage struct {
	PackageLength uint32
	Command       Command
	Flags         byte
	CorrelationID []byte
	Login         string
	Password      string
	Data          []byte
}