s3

Documentation

Index

• Constants
• Variables
• func ListenAndServe(addr string, cacheSize uint) error
• func NewServer() (*grpc.Server, error)
• type Client
  • func NewClient(addr string) (*Client, error)
  • func (c *Client) GetBlock(ctx context.Context, info *pb.BlockInfo, noCache bool) (header *pb.Block, err error)
  • func (c *Client) GetConn() *grpc.ClientConn
  • func (c *Client) GetFile(ctx context.Context, key string) ([]byte, error)
  • func (c *Client) ListHeaderStartAt(ctx context.Context, chainId, env, role string, blockNum int64, count int64, ...) (info []*pb.BlockInfo, err error)
  • func (c *Client) PutBlock(ctx context.Context, block *pb.Block) (err error)
  • func (c *Client) PutFile(ctx context.Context, key string, buf []byte) error
  • func (c *Client) RemoveFiles(ctx context.Context, infos []*pb.BlockInfo) error
  • func (c *Client) ResetConn() error

Constants

const (
	BucketName = "prod-blockchain-replicator"
	ChunkSize  = 1 << 22
	Region     = "ap-northeast-1"
)

Variables

var MaxCacheSize uint = 256

Functions

func ListenAndServe

func ListenAndServe(addr string, cacheSize uint) error

func NewServer

func NewServer() (*grpc.Server, error)

Types

type Client

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

func NewClient

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

func (*Client) GetBlock

func (c *Client) GetBlock(ctx context.Context, info *pb.BlockInfo, noCache bool) (header *pb.Block, err error)

func (*Client) GetConn

func (c *Client) GetConn() *grpc.ClientConn

func (*Client) GetFile

func (c *Client) GetFile(ctx context.Context, key string) ([]byte, error)

func (*Client) ListHeaderStartAt

func (c *Client) ListHeaderStartAt(ctx context.Context, chainId, env, role string, blockNum int64, count int64, after int64) (info []*pb.BlockInfo, err error)

func (*Client) PutBlock

func (c *Client) PutBlock(ctx context.Context, block *pb.Block) (err error)

func (*Client) PutFile

func (c *Client) PutFile(ctx context.Context, key string, buf []byte) error

func (*Client) RemoveFiles

func (c *Client) RemoveFiles(ctx context.Context, infos []*pb.BlockInfo) error

func (*Client) ResetConn

func (c *Client) ResetConn() error