ebt

type FeedRequester interface {
	Request(ctx context.Context, ref refs.Feed, seq *message.Sequence)
	Cancel(ref refs.Feed)
}

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

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

type MessageStreamer interface {
	Handle(ctx context.Context, id refs.Feed, seq *message.Sequence, messageWriter MessageWriter)
}

type MessageWriter interface {
	WriteMessage(msg message.Message) error
}

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

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

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

type Runner interface {
	HandleStream(ctx context.Context, stream Stream) error
}

type SelfCreateHistoryStreamReplicator interface {
	// ReplicateSelf should keep attempting to perform replication as long as
	// the context isn't closed. Returning an error implies that replication
	// should not restart.
	ReplicateSelf(ctx context.Context, peer transport.Peer) error
}

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

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

type SessionEndedFn func()

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

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

type Stream interface {
	RemoteIdentity() identity.Public
	IncomingMessages(ctx context.Context) <-chan IncomingMessage
	SendNotes(notes messages.EbtReplicateNotes) error
	SendMessage(msg *message.Message) error
}

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

type Tracker interface {
	OpenSession(id rpc.ConnectionId) (SessionEndedFn, error)

	// WaitForSession waits for the session to be started for the provided
	// amount of time. If the session starts within the provided time window
	// then WaitForSession blocks for as long as the session is running.
	// Returning true signifies that the session existed at any point after
	// calling this function. Error is returned if the context is cancelled.
	WaitForSession(ctx context.Context, id rpc.ConnectionId, waitTime time.Duration) (bool, error)
}