Versions in this module Expand all Collapse all v0 v0.1.1 May 16, 2026 v0.1.0 Mar 12, 2026 Changes in this version + func EncodeSessionCreateRequest(req *SessionCreateRequest) []byte + type AttestationMessage struct + AttestationID core.ID + CommitRoot core.ID + OutputHash core.ID + SessionID core.ID + StepIndex uint32 + func DecodeAttestationMessage(data []byte) (*AttestationMessage, error) + type Config struct + BootstrapPeers []string + DataDir string + HeartbeatInterval time.Duration + ListenAddr string + MaxSessions int + NodeID core.ID + SessionTimeout time.Duration + func DefaultConfig() *Config + type OracleCommitMessage struct + RequestID core.ID + type OracleRecordMessage struct + Data []byte + RequestID core.ID + Signature []byte + SubmitterID core.ID + func DecodeOracleRecordMessage(data []byte) (*OracleRecordMessage, error) + type OracleRequestMessage struct + InputHash core.ID + SessionID core.ID + StepKind core.StepKind + TxID core.ID + func DecodeOracleRequestMessage(data []byte) (*OracleRequestMessage, error) + type Service struct + func New(config *Config) *Service + func (s *Service) CreateSession(serviceID core.ID, epoch uint64, txID core.ID, committee []core.ID) (*core.Session, error) + func (s *Service) FinalizeSession(sessionID, outputHash, oracleRoot, receiptsRoot core.ID) error + func (s *Service) GetSession(sessionID core.ID) (*core.Session, error) + func (s *Service) Start(ctx context.Context) error + func (s *Service) StartSession(sessionID core.ID) error + func (s *Service) Stop() error + type SessionCreateRequest struct + Committee []core.ID + Epoch uint64 + ServiceID core.ID + TxID core.ID + func DecodeSessionCreateRequest(data []byte) (*SessionCreateRequest, error) + type SessionRunner struct + func NewSessionRunner(service *Service, session *core.Session) *SessionRunner + func (r *SessionRunner) CompleteStep(stepIndex uint32, oracleCommitRoot, attestationID, outputHash core.ID) error + func (r *SessionRunner) CreateOracleRequest(kind core.StepKind, txID, inputHash core.ID) (*protocol.OracleRequest, error) + func (r *SessionRunner) Finalize(outputHash, oracleRoot, receiptsRoot core.ID) error + func (r *SessionRunner) Session() *core.Session + func (r *SessionRunner) Start(ctx context.Context) error + func (r *SessionRunner) Stop()
Go to main page