Enum PoolMessageCS 

pub enum PoolMessageCS<N: Network> {
    Connect(u8, u8, u8, u8, u8, String, String),
    Submit(u32, u64, Data<ProverSolution<N>>),
    DisConnect(u32),
    Ping,
    Unused,
}

Variants

Connect(u8, u8, u8, u8, u8, String, String)

Connect := (type, address_type, version(major, minor, patch), name, address)

Submit(u32, u64, Data<ProverSolution<N>>)

submit := (work_id, job_id, address, prover_solution)

DisConnect(u32)

DisConnect := (id)

Ping

Ping

Unused

Implementations

impl<N: Network> PoolMessageCS<N>

pub fn name(&self) -> &str

Returns the messge name

pub fn id(&self) -> u8

Returns the message ID.

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

Returns the message data as bytes.

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

Serializes the given message into bytes.

pub fn deserialize(buffer: &[u8]) -> Result<Self>

Deserializes the given buffer into a message.

Trait Implementations

impl<N: Clone + Network> Clone for PoolMessageCS<N>

fn clone(&self) -> PoolMessageCS<N>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<N: Debug + Network> Debug for PoolMessageCS<N>

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

Formats the value using the given formatter.

impl<N: Network> Decoder for PoolMessageCS<N>

type Error = Error

The type of unrecoverable frame decoding errors.

type Item = PoolMessageCS<N>

The type of decoded frames.

fn decode( &mut self, source: &mut BytesMut, ) -> Result<Option<Self::Item>, Self::Error>

Attempts to decode a frame from the provided buffer of bytes.

fn decode_eof( &mut self, buf: &mut BytesMut, ) -> Result<Option<Self::Item>, Self::Error>

A default method available to be called when there are no more bytes available to be read from the underlying I/O.

fn framed<T>(self, io: T) -> Framed<T, Self>

where T: AsyncRead + AsyncWrite, Self: Sized,

Provides a Stream and Sink interface for reading and writing to this Io object, using Decode and Encode to read and write the raw data.

impl<N: Network> Default for PoolMessageCS<N>

fn default() -> Self

Returns the “default value” for a type.

impl<N: Network> Encoder<PoolMessageCS<N>> for PoolMessageCS<N>

type Error = Error

The type of encoding errors.

fn encode( &mut self, message: PoolMessageCS<N>, dst: &mut BytesMut, ) -> Result<(), Self::Error>

Encodes a frame into the buffer provided.