ssb

Documentation

Index

• type Client
  • func (c *Client) LogStream() (chan []byte, error)
  • func (c *Client) ReceiveLast(id, contentType string, limit int64) ([]byte, error)
  • func (c *Client) Transmit(v interface{}) ([]byte, error)
  • func (c *Client) WhoAmI() ([]byte, error)
• type Config
  • func (cfg *Config) Client(ctx context.Context) (*Client, error)
• type Endpoint
• type FeedAssetPrice

Types

type Client

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

func (*Client) LogStream

func (c *Client) LogStream() (chan []byte, error)

func (*Client) ReceiveLast

func (c *Client) ReceiveLast(id, contentType string, limit int64) ([]byte, error)

func (*Client) Transmit

func (c *Client) Transmit(v interface{}) ([]byte, error)

func (*Client) WhoAmI

func (c *Client) WhoAmI() ([]byte, error)

type Config

type Config struct {
	Keys ssb.KeyPair
	Shs  string
	Addr net.Addr
}

func (*Config) Client

func (cfg *Config) Client(ctx context.Context) (*Client, error)

type Endpoint

type Endpoint interface {
	Async(context.Context, interface{}, muxrpc.RequestEncoding, muxrpc.Method, ...interface{}) error
	Source(context.Context, muxrpc.RequestEncoding, muxrpc.Method, ...interface{}) (*muxrpc.ByteSource, error)
}

type FeedAssetPrice

type FeedAssetPrice struct {
	Type           string          `json:"type"`
	Version        string          `json:"version"`
	Price          float64         `json:"price"`
	PriceHex       string          `json:"priceHex"`
	Time           int             `json:"time"`
	TimeHex        string          `json:"timeHex"`
	Hash           string          `json:"hash"`
	Signature      string          `json:"signature"`
	Sources        json.RawMessage `json:"sources"`
	StarkSignature json.RawMessage `json:"starkSignature"`
}