eventlog

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

type Event struct {
	Timestamp int64
	EventType proto.EventType
	PeerInfo  *proto.PeerInfo
	Error     error
}

type EventlogSync interface {
	Acquire(instanceID string, tunnelID string, ttl time.Duration) (bool, error)
	Release(instanceID string, tunnelID string) error

	GetPosition(tunnelID string) (Position, error)
	PutPosition(tunnelID string, position Position) error
	DeletePosition(tunnelID string) error
}

type Option func(opts *options) error

type Position struct {
	LogID  string `json:"log_id"`
	Offset int64  `json:"offset"`
}