Struct Thread 

pub struct Thread {

    pub version: u8,
    pub bump: u8,
    pub authority: Pubkey,
    pub id: Vec<u8>,
    pub name: String,
    pub created_at: i64,
    pub trigger: Trigger,
    pub schedule: Schedule,
    pub fiber_ids: Vec<u8>,
    pub fiber_cursor: u8,
    pub fiber_next_id: u8,
    pub fiber_signal: Signal,
    pub paused: bool,
    pub exec_count: u64,
    pub last_executor: Pubkey,
    pub nonce_account: Pubkey,
    pub last_nonce: String,
    pub close_fiber: Vec<u8>,
}

Tracks the current state of a transaction thread on Solana.

Fields

version: u8

bump: u8

authority: Pubkey

id: Vec<u8>

name: String

created_at: i64

trigger: Trigger

schedule: Schedule

fiber_ids: Vec<u8>

fiber_cursor: u8

fiber_next_id: u8

fiber_signal: Signal

paused: bool

exec_count: u64

last_executor: Pubkey

nonce_account: Pubkey

last_nonce: String

close_fiber: Vec<u8>

Implementations

impl Thread

pub fn pubkey(authority: Pubkey, id: impl AsRef<[u8]>) -> Pubkey

Derive the pubkey of a thread account.

pub fn has_nonce_account(&self) -> bool

Check if this thread has a nonce account.

pub fn advance_to_next_fiber(&mut self)

Advance fiber_cursor to the next fiber in the sequence.

pub fn next_fiber_index(&self) -> u8

Get the next fiber index in sequence (without mutating). Used to validate Chain signals target the correct consecutive fiber.

pub fn fiber(&self, thread_pubkey: &Pubkey) -> Pubkey

Get the fiber PDA for the current fiber_cursor

pub fn fiber_at_index(&self, thread_pubkey: &Pubkey, fiber_index: u8) -> Pubkey

Get the fiber PDA for a specific fiber_index

pub fn next_fiber(&self, thread_pubkey: &Pubkey) -> Pubkey

Get the next fiber PDA (for the next fiber_cursor in the sequence)

pub fn is_ready(&self, current_slot: u64, current_timestamp: i64) -> bool

Check if thread is ready to execute based on schedule

pub fn validate_for_execution(&self) -> Result<()>

Validate that the thread is ready for execution

Trait Implementations

impl AccountDeserialize for Thread

fn try_deserialize(buf: &mut &[u8]) -> Result<Self>

Deserializes previously initialized account data. Should fail for all uninitialized accounts, where the bytes are zeroed. Implementations should be unique to a particular account type so that one can never successfully deserialize the data of one account type into another. For example, if the SPL token program were to implement this trait, it should be impossible to deserialize a Mint account into a token Account.

fn try_deserialize_unchecked(buf: &mut &[u8]) -> Result<Self>

Deserializes account data without checking the account discriminator. This should only be used on account initialization, when the bytes of the account are zeroed.

impl AccountSerialize for Thread

fn try_serialize<W: Write>(&self, writer: &mut W) -> Result<()>

Serializes the account data into writer.

impl BorshDeserialize for Thread

fn deserialize_reader<__R: Read>(reader: &mut __R) -> Result<Self, Error>

fn deserialize(buf: &mut &[u8]) -> Result<Self, Error>

Deserializes this instance from a given slice of bytes. Updates the buffer to point at the remaining bytes.

fn try_from_slice(v: &[u8]) -> Result<Self, Error>

Deserialize this instance from a slice of bytes.

fn try_from_reader<R>(reader: &mut R) -> Result<Self, Error>

where R: Read,

impl BorshSerialize for Thread

fn serialize<__W: Write>(&self, writer: &mut __W) -> Result<(), Error>

impl Clone for Thread

fn clone(&self) -> Thread

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Thread

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Discriminator for Thread

const DISCRIMINATOR: &'static [u8]

Discriminator slice.

impl NonceProcessor for Thread

fn advance_nonce_if_required<'info>( &self, thread_account_info: &AccountInfo<'info>, nonce_account: &Option<UncheckedAccount<'info>>, recent_blockhashes: &Option<UncheckedAccount<'info>>, ) -> Result<()>

impl Owner for Thread

fn owner() -> Pubkey

impl PaymentDistributor for Thread

fn distribute_payments<'info>( &self, thread_account: &AccountInfo<'info>, executor: &AccountInfo<'info>, admin: &AccountInfo<'info>, payments: &PaymentDetails, ) -> Result<()>

impl Space for Thread

const INIT_SPACE: usize

impl ThreadSeeds for Thread

fn get_seed_bytes(&self) -> Vec<Vec<u8>>

fn sign<F, R>(&self, f: F) -> R

where F: FnOnce(&[&[u8]]) -> R,

Use seeds with a callback to avoid lifetime issues

impl TriggerProcessor for Thread

fn validate_trigger( &self, clock: &Clock, remaining_accounts: &[AccountInfo<'_>], thread_pubkey: &Pubkey, ) -> Result<i64>

fn update_schedule( &mut self, clock: &Clock, remaining_accounts: &[AccountInfo<'_>], thread_pubkey: &Pubkey, ) -> Result<()>

fn get_last_started_at(&self) -> i64

impl TryFrom<Vec<u8>> for Thread

type Error = Error

The type returned in the event of a conversion error.

fn try_from(data: Vec<u8>) -> Result<Self, Self::Error>

Performs the conversion.