thoughtstream

type AgentLog struct {
	*os.File
	// contains filtered or unexported fields
}

type Branch interface {
	psi.Node

	Iterable
	ParentBranch() Branch
	Base() *Thought
	Head() *Thought

	ParentPointer() Pointer
	BasePointer() Pointer
	HeadPointer() Pointer

	Interval() Interval

	Stream() Stream
	Mutate() MutableStream

	Fork(options ...ForkOption) MutableStream

	Len() int
}

type CommHandle struct {
	ID   string
	Name string
	Role msn.Role
}

type ForkOption func(*ForkOptions)

type ForkOptions struct {
}

type Interval struct {
	Start Pointer
	End   Pointer
}

type Iterable = iterators.Iterable[*Thought]

type Iterator = iterators.Iterator[*Thought]

type Manager struct {
	psi.NodeBase
	// contains filtered or unexported fields
}

type MergeOption func(*MergeOptions)

type MergeOptions struct {
}

type MergeStrategy interface {
	Apply(ctx context.Context, s MutableStream, streams ...Stream) (Iterator, error)
}

type MergeStrategyFunc func(ctx context.Context, s MutableStream, streams ...Stream) (Iterator, error)

type MutableStream interface {
	Stream

	Append(t *Thought)

	Merge(ctx context.Context, r Resolver, strategy MergeStrategy, branches ...Branch) error
}

type Pointer struct {
	Parent    string
	Previous  string
	Timestamp time.Time
	Level     int64
	Clock     int64
}

type Reference struct {
	Path psi.Path
}

type Repo struct {
}

type Resolver interface {
	ResolveThought(ctx context.Context, id cid.Cid) (*Thought, error)
	ResolveBranch(ctx context.Context, id cid.Cid) (Branch, error)
}

type Stream interface {
	Iterator
	Iterable

	Previous() bool
	Reversed() Stream

	Pointer() Pointer
	Thought() *Thought

	LA(n int) *Thought
	Peek() *Thought
	Seek(p Pointer) error
	Slice(from, to Pointer) Stream

	Fork(options ...ForkOption) MutableStream

	AsBranch() Branch
}

type ThoughLogListener func(msg *Thought)

type Thought struct {
	psi.NodeBase

	Pointer Pointer
	From    CommHandle
	Text    string

	ReplyTo *CommHandle
}

type ThoughtLog struct {
	psi.NodeBase
	// contains filtered or unexported fields
}