impl

Documentation

Index

• Variables
• type Client
  • func NewClient(serverAddr string) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) FetchTimestamp(ctx context.Context) (uint64, error)
  • func (c *Client) TargetAddr() string
• type Server
  • func NewServer(port int, oracle oracle.Oracle, store *topo.Store) *Server
  • func (s *Server) Close() error
  • func (s *Server) Start() error
• type Stub
  • func (o *Stub) Fetch(ctx context.Context, _ *oraclepb.FetchRequest) (*oraclepb.FetchResponse, error)

Variables

var NilFetchResponse = fmt.Errorf("nil fetch resp")

Types

type Client

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

func NewClient

func NewClient(serverAddr string) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) FetchTimestamp

func (c *Client) FetchTimestamp(ctx context.Context) (uint64, error)

func (*Client) TargetAddr

func (c *Client) TargetAddr() string

type Server

type Server struct {
	Port int

	Done chan struct{}
	// contains filtered or unexported fields
}

func NewServer

func NewServer(port int, oracle oracle.Oracle, store *topo.Store) *Server

func (*Server) Close

func (s *Server) Close() error

func (*Server) Start

func (s *Server) Start() error

type Stub

type Stub struct {
	oraclepb.UnimplementedOracleServer
	// contains filtered or unexported fields
}

func (*Stub) Fetch

func (o *Stub) Fetch(ctx context.Context, _ *oraclepb.FetchRequest) (*oraclepb.FetchResponse, error)