pbfunnel

Documentation

Index

• func RegisterFunnelServer(s *grpc.Server, srv FunnelServer)
• type FunnelClient
  • func NewFunnelClient(cc grpc.ClientConnInterface) FunnelClient
• type FunnelServer
• type Funnel_StreamBlocksClient
• type Funnel_StreamBlocksServer
• type StreamBlockRequest
  • func (*StreamBlockRequest) Descriptor() ([]byte, []int)
  • func (m *StreamBlockRequest) GetFromBlockNum() int64
  • func (m *StreamBlockRequest) GetIrreversibleOnly() bool
  • func (*StreamBlockRequest) ProtoMessage()
  • func (m *StreamBlockRequest) Reset()
  • func (m *StreamBlockRequest) String() string
  • func (m *StreamBlockRequest) XXX_DiscardUnknown()
  • func (m *StreamBlockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *StreamBlockRequest) XXX_Merge(src proto.Message)
  • func (m *StreamBlockRequest) XXX_Size() int
  • func (m *StreamBlockRequest) XXX_Unmarshal(b []byte) error
• type StreamBlockResponse
  • func (*StreamBlockResponse) Descriptor() ([]byte, []int)
  • func (m *StreamBlockResponse) GetBlock() *v1.Block
  • func (m *StreamBlockResponse) GetUndo() bool
  • func (*StreamBlockResponse) ProtoMessage()
  • func (m *StreamBlockResponse) Reset()
  • func (m *StreamBlockResponse) String() string
  • func (m *StreamBlockResponse) XXX_DiscardUnknown()
  • func (m *StreamBlockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *StreamBlockResponse) XXX_Merge(src proto.Message)
  • func (m *StreamBlockResponse) XXX_Size() int
  • func (m *StreamBlockResponse) XXX_Unmarshal(b []byte) error
• type UnimplementedFunnelServer
  • func (*UnimplementedFunnelServer) StreamBlocks(req *StreamBlockRequest, srv Funnel_StreamBlocksServer) error

Functions

func RegisterFunnelServer

func RegisterFunnelServer(s *grpc.Server, srv FunnelServer)

Types

type FunnelClient

type FunnelClient interface {
	StreamBlocks(ctx context.Context, in *StreamBlockRequest, opts ...grpc.CallOption) (Funnel_StreamBlocksClient, error)
}

FunnelClient is the client API for Funnel service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFunnelClient

func NewFunnelClient(cc grpc.ClientConnInterface) FunnelClient

type FunnelServer

type FunnelServer interface {
	StreamBlocks(*StreamBlockRequest, Funnel_StreamBlocksServer) error
}

FunnelServer is the server API for Funnel service.

type Funnel_StreamBlocksClient

type Funnel_StreamBlocksClient interface {
	Recv() (*StreamBlockResponse, error)
	grpc.ClientStream
}

type Funnel_StreamBlocksServer

type Funnel_StreamBlocksServer interface {
	Send(*StreamBlockResponse) error
	grpc.ServerStream
}

type StreamBlockRequest

type StreamBlockRequest struct {
	FromBlockNum         int64    `protobuf:"varint,2,opt,name=fromBlockNum,proto3" json:"fromBlockNum,omitempty"`
	IrreversibleOnly     bool     `protobuf:"varint,3,opt,name=irreversibleOnly,proto3" json:"irreversibleOnly,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamBlockRequest) Descriptor

func (*StreamBlockRequest) Descriptor() ([]byte, []int)

func (*StreamBlockRequest) GetFromBlockNum

func (m *StreamBlockRequest) GetFromBlockNum() int64

func (*StreamBlockRequest) GetIrreversibleOnly

func (m *StreamBlockRequest) GetIrreversibleOnly() bool

func (*StreamBlockRequest) ProtoMessage

func (*StreamBlockRequest) ProtoMessage()

func (*StreamBlockRequest) Reset

func (m *StreamBlockRequest) Reset()

func (*StreamBlockRequest) String

func (m *StreamBlockRequest) String() string

func (*StreamBlockRequest) XXX_DiscardUnknown

func (m *StreamBlockRequest) XXX_DiscardUnknown()

func (*StreamBlockRequest) XXX_Marshal

func (m *StreamBlockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamBlockRequest) XXX_Merge

func (m *StreamBlockRequest) XXX_Merge(src proto.Message)

func (*StreamBlockRequest) XXX_Size

func (m *StreamBlockRequest) XXX_Size() int

func (*StreamBlockRequest) XXX_Unmarshal

func (m *StreamBlockRequest) XXX_Unmarshal(b []byte) error

type StreamBlockResponse

type StreamBlockResponse struct {
	Undo                 bool      `protobuf:"varint,1,opt,name=undo,proto3" json:"undo,omitempty"`
	Block                *v1.Block `protobuf:"bytes,2,opt,name=block,proto3" json:"block,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*StreamBlockResponse) Descriptor

func (*StreamBlockResponse) Descriptor() ([]byte, []int)

func (*StreamBlockResponse) GetBlock

func (m *StreamBlockResponse) GetBlock() *v1.Block

func (*StreamBlockResponse) GetUndo

func (m *StreamBlockResponse) GetUndo() bool

func (*StreamBlockResponse) ProtoMessage

func (*StreamBlockResponse) ProtoMessage()

func (*StreamBlockResponse) Reset

func (m *StreamBlockResponse) Reset()

func (*StreamBlockResponse) String

func (m *StreamBlockResponse) String() string

func (*StreamBlockResponse) XXX_DiscardUnknown

func (m *StreamBlockResponse) XXX_DiscardUnknown()

func (*StreamBlockResponse) XXX_Marshal

func (m *StreamBlockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamBlockResponse) XXX_Merge

func (m *StreamBlockResponse) XXX_Merge(src proto.Message)

func (*StreamBlockResponse) XXX_Size

func (m *StreamBlockResponse) XXX_Size() int

func (*StreamBlockResponse) XXX_Unmarshal

func (m *StreamBlockResponse) XXX_Unmarshal(b []byte) error

type UnimplementedFunnelServer

type UnimplementedFunnelServer struct {
}

UnimplementedFunnelServer can be embedded to have forward compatible implementations.

func (*UnimplementedFunnelServer) StreamBlocks

func (*UnimplementedFunnelServer) StreamBlocks(req *StreamBlockRequest, srv Funnel_StreamBlocksServer) error