tendermint: github.com/tendermint/tendermint/rpc/grpc Index | Files

package core_grpc

import "github.com/tendermint/tendermint/rpc/grpc"

Index

Package Files

api.go client_server.go types.pb.go

Variables

var (
    ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowTypes   = fmt.Errorf("proto: integer overflow")
)

func RegisterBroadcastAPIServer Uses

func RegisterBroadcastAPIServer(s *grpc.Server, srv BroadcastAPIServer)

func StartGRPCServer Uses

func StartGRPCServer(ln net.Listener) error

StartGRPCServer starts a new gRPC BroadcastAPIServer using the given net.Listener. NOTE: This function blocks - you may want to call it in a go-routine.

type BroadcastAPIClient Uses

type BroadcastAPIClient interface {
    Ping(ctx context.Context, in *RequestPing, opts ...grpc.CallOption) (*ResponsePing, error)
    BroadcastTx(ctx context.Context, in *RequestBroadcastTx, opts ...grpc.CallOption) (*ResponseBroadcastTx, error)
}

BroadcastAPIClient is the client API for BroadcastAPI service.

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

func NewBroadcastAPIClient Uses

func NewBroadcastAPIClient(cc *grpc.ClientConn) BroadcastAPIClient

func StartGRPCClient Uses

func StartGRPCClient(protoAddr string) BroadcastAPIClient

StartGRPCClient dials the gRPC server using protoAddr and returns a new BroadcastAPIClient.

type BroadcastAPIServer Uses

type BroadcastAPIServer interface {
    Ping(context.Context, *RequestPing) (*ResponsePing, error)
    BroadcastTx(context.Context, *RequestBroadcastTx) (*ResponseBroadcastTx, error)
}

BroadcastAPIServer is the server API for BroadcastAPI service.

type Config Uses

type Config struct {
    MaxOpenConnections int
}

Config is an gRPC server configuration.

type RequestBroadcastTx Uses

type RequestBroadcastTx struct {
    Tx                   []byte   `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedRequestBroadcastTx Uses

func NewPopulatedRequestBroadcastTx(r randyTypes, easy bool) *RequestBroadcastTx

func (*RequestBroadcastTx) Descriptor Uses

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

func (*RequestBroadcastTx) Equal Uses

func (this *RequestBroadcastTx) Equal(that interface{}) bool

func (*RequestBroadcastTx) GetTx Uses

func (m *RequestBroadcastTx) GetTx() []byte

func (*RequestBroadcastTx) Marshal Uses

func (m *RequestBroadcastTx) Marshal() (dAtA []byte, err error)

func (*RequestBroadcastTx) MarshalTo Uses

func (m *RequestBroadcastTx) MarshalTo(dAtA []byte) (int, error)

func (*RequestBroadcastTx) ProtoMessage Uses

func (*RequestBroadcastTx) ProtoMessage()

func (*RequestBroadcastTx) Reset Uses

func (m *RequestBroadcastTx) Reset()

func (*RequestBroadcastTx) Size Uses

func (m *RequestBroadcastTx) Size() (n int)

func (*RequestBroadcastTx) String Uses

func (m *RequestBroadcastTx) String() string

func (*RequestBroadcastTx) Unmarshal Uses

func (m *RequestBroadcastTx) Unmarshal(dAtA []byte) error

func (*RequestBroadcastTx) XXX_DiscardUnknown Uses

func (m *RequestBroadcastTx) XXX_DiscardUnknown()

func (*RequestBroadcastTx) XXX_Marshal Uses

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

func (*RequestBroadcastTx) XXX_Merge Uses

func (dst *RequestBroadcastTx) XXX_Merge(src proto.Message)

func (*RequestBroadcastTx) XXX_Size Uses

func (m *RequestBroadcastTx) XXX_Size() int

func (*RequestBroadcastTx) XXX_Unmarshal Uses

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

type RequestPing Uses

type RequestPing struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedRequestPing Uses

func NewPopulatedRequestPing(r randyTypes, easy bool) *RequestPing

func (*RequestPing) Descriptor Uses

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

func (*RequestPing) Equal Uses

func (this *RequestPing) Equal(that interface{}) bool

func (*RequestPing) Marshal Uses

func (m *RequestPing) Marshal() (dAtA []byte, err error)

func (*RequestPing) MarshalTo Uses

func (m *RequestPing) MarshalTo(dAtA []byte) (int, error)

func (*RequestPing) ProtoMessage Uses

func (*RequestPing) ProtoMessage()

func (*RequestPing) Reset Uses

func (m *RequestPing) Reset()

func (*RequestPing) Size Uses

func (m *RequestPing) Size() (n int)

func (*RequestPing) String Uses

func (m *RequestPing) String() string

func (*RequestPing) Unmarshal Uses

func (m *RequestPing) Unmarshal(dAtA []byte) error

func (*RequestPing) XXX_DiscardUnknown Uses

func (m *RequestPing) XXX_DiscardUnknown()

func (*RequestPing) XXX_Marshal Uses

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

func (*RequestPing) XXX_Merge Uses

func (dst *RequestPing) XXX_Merge(src proto.Message)

func (*RequestPing) XXX_Size Uses

func (m *RequestPing) XXX_Size() int

func (*RequestPing) XXX_Unmarshal Uses

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

type ResponseBroadcastTx Uses

type ResponseBroadcastTx struct {
    CheckTx              *types.ResponseCheckTx   `protobuf:"bytes,1,opt,name=check_tx,json=checkTx" json:"check_tx,omitempty"`
    DeliverTx            *types.ResponseDeliverTx `protobuf:"bytes,2,opt,name=deliver_tx,json=deliverTx" json:"deliver_tx,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
    XXX_unrecognized     []byte                   `json:"-"`
    XXX_sizecache        int32                    `json:"-"`
}

func NewPopulatedResponseBroadcastTx Uses

func NewPopulatedResponseBroadcastTx(r randyTypes, easy bool) *ResponseBroadcastTx

func (*ResponseBroadcastTx) Descriptor Uses

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

func (*ResponseBroadcastTx) Equal Uses

func (this *ResponseBroadcastTx) Equal(that interface{}) bool

func (*ResponseBroadcastTx) GetCheckTx Uses

func (m *ResponseBroadcastTx) GetCheckTx() *types.ResponseCheckTx

func (*ResponseBroadcastTx) GetDeliverTx Uses

func (m *ResponseBroadcastTx) GetDeliverTx() *types.ResponseDeliverTx

func (*ResponseBroadcastTx) Marshal Uses

func (m *ResponseBroadcastTx) Marshal() (dAtA []byte, err error)

func (*ResponseBroadcastTx) MarshalTo Uses

func (m *ResponseBroadcastTx) MarshalTo(dAtA []byte) (int, error)

func (*ResponseBroadcastTx) ProtoMessage Uses

func (*ResponseBroadcastTx) ProtoMessage()

func (*ResponseBroadcastTx) Reset Uses

func (m *ResponseBroadcastTx) Reset()

func (*ResponseBroadcastTx) Size Uses

func (m *ResponseBroadcastTx) Size() (n int)

func (*ResponseBroadcastTx) String Uses

func (m *ResponseBroadcastTx) String() string

func (*ResponseBroadcastTx) Unmarshal Uses

func (m *ResponseBroadcastTx) Unmarshal(dAtA []byte) error

func (*ResponseBroadcastTx) XXX_DiscardUnknown Uses

func (m *ResponseBroadcastTx) XXX_DiscardUnknown()

func (*ResponseBroadcastTx) XXX_Marshal Uses

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

func (*ResponseBroadcastTx) XXX_Merge Uses

func (dst *ResponseBroadcastTx) XXX_Merge(src proto.Message)

func (*ResponseBroadcastTx) XXX_Size Uses

func (m *ResponseBroadcastTx) XXX_Size() int

func (*ResponseBroadcastTx) XXX_Unmarshal Uses

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

type ResponsePing Uses

type ResponsePing struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedResponsePing Uses

func NewPopulatedResponsePing(r randyTypes, easy bool) *ResponsePing

func (*ResponsePing) Descriptor Uses

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

func (*ResponsePing) Equal Uses

func (this *ResponsePing) Equal(that interface{}) bool

func (*ResponsePing) Marshal Uses

func (m *ResponsePing) Marshal() (dAtA []byte, err error)

func (*ResponsePing) MarshalTo Uses

func (m *ResponsePing) MarshalTo(dAtA []byte) (int, error)

func (*ResponsePing) ProtoMessage Uses

func (*ResponsePing) ProtoMessage()

func (*ResponsePing) Reset Uses

func (m *ResponsePing) Reset()

func (*ResponsePing) Size Uses

func (m *ResponsePing) Size() (n int)

func (*ResponsePing) String Uses

func (m *ResponsePing) String() string

func (*ResponsePing) Unmarshal Uses

func (m *ResponsePing) Unmarshal(dAtA []byte) error

func (*ResponsePing) XXX_DiscardUnknown Uses

func (m *ResponsePing) XXX_DiscardUnknown()

func (*ResponsePing) XXX_Marshal Uses

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

func (*ResponsePing) XXX_Merge Uses

func (dst *ResponsePing) XXX_Merge(src proto.Message)

func (*ResponsePing) XXX_Size Uses

func (m *ResponsePing) XXX_Size() int

func (*ResponsePing) XXX_Unmarshal Uses

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

Package core_grpc imports 15 packages (graph) and is imported by 8 packages. Updated 2019-07-26. Refresh now. Tools for package owners.