agent

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

type BalanceCollector interface {
	GetBalance(account *keypair.FromAddress, asset state.Asset) (int64, error)
}

type ClosedEvent struct{}

type ClosingEvent struct{}

type ClosingWithOutdatedStateEvent struct{}

type Config struct {
	ObservationPeriodTime      time.Duration
	ObservationPeriodLedgerGap uint32
	MaxOpenExpiry              time.Duration
	NetworkPassphrase          string

	SequenceNumberCollector SequenceNumberCollector
	BalanceCollector        BalanceCollector
	Submitter               Submitter
	Streamer                Streamer
	Snapshotter             Snapshotter

	ChannelAccountKey    *keypair.FromAddress
	ChannelAccountSigner *keypair.Full

	LogWriter io.Writer

	Events chan<- interface{}
}

type ConnectedEvent struct {
	ChannelAccount *keypair.FromAddress
	Signer         *keypair.FromAddress
}

type ErrorEvent struct {
	Err error
}

type OpenedEvent struct {
	OpenAgreement state.OpenAgreement
}

type PaymentReceivedEvent struct {
	CloseAgreement state.CloseAgreement
}

type PaymentSentEvent struct {
	CloseAgreement state.CloseAgreement
}

type SequenceNumberCollector interface {
	GetSequenceNumber(account *keypair.FromAddress) (int64, error)
}

type Snapshot struct {
	OtherChannelAccount       *keypair.FromAddress
	OtherChannelAccountSigner *keypair.FromAddress
	StreamerCursor            string
	State                     *struct {
		Initiator bool
		Snapshot  state.Snapshot
	}
}

type Snapshotter interface {
	Snapshot(a *Agent, s Snapshot)
}

type StreamedTransaction struct {
	// Cursor is a cursor that can be used to resume streaming.
	Cursor string

	// TransactionOrderID is an identifier that orders transactions in the order
	// they were executed on the Stellar network.
	TransactionOrderID int64

	TransactionXDR string
	ResultXDR      string
	ResultMetaXDR  string
}

type Streamer interface {
	StreamTx(cursor string, accounts ...*keypair.FromAddress) (transactions <-chan StreamedTransaction, cancel func())
}

type Submitter interface {
	SubmitTx(tx *txnbuild.Transaction) error
}