Documentation ¶
Index ¶
- Variables
- func RegisterBroadcastAPIServer(s *grpc.Server, srv BroadcastAPIServer)
- func StartGRPCServer(ln net.Listener) error
- type BroadcastAPIClient
- type BroadcastAPIServer
- type Config
- type RequestBroadcastTx
- func (*RequestBroadcastTx) Descriptor() ([]byte, []int)
- func (this *RequestBroadcastTx) Equal(that interface{}) bool
- func (m *RequestBroadcastTx) GetTx() []byte
- func (m *RequestBroadcastTx) Marshal() (dAtA []byte, err error)
- func (m *RequestBroadcastTx) MarshalTo(dAtA []byte) (int, error)
- func (*RequestBroadcastTx) ProtoMessage()
- func (m *RequestBroadcastTx) Reset()
- func (m *RequestBroadcastTx) Size() (n int)
- func (m *RequestBroadcastTx) String() string
- func (m *RequestBroadcastTx) Unmarshal(dAtA []byte) error
- func (m *RequestBroadcastTx) XXX_DiscardUnknown()
- func (m *RequestBroadcastTx) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RequestBroadcastTx) XXX_Merge(src proto.Message)
- func (m *RequestBroadcastTx) XXX_Size() int
- func (m *RequestBroadcastTx) XXX_Unmarshal(b []byte) error
- type RequestPing
- func (*RequestPing) Descriptor() ([]byte, []int)
- func (this *RequestPing) Equal(that interface{}) bool
- func (m *RequestPing) Marshal() (dAtA []byte, err error)
- func (m *RequestPing) MarshalTo(dAtA []byte) (int, error)
- func (*RequestPing) ProtoMessage()
- func (m *RequestPing) Reset()
- func (m *RequestPing) Size() (n int)
- func (m *RequestPing) String() string
- func (m *RequestPing) Unmarshal(dAtA []byte) error
- func (m *RequestPing) XXX_DiscardUnknown()
- func (m *RequestPing) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RequestPing) XXX_Merge(src proto.Message)
- func (m *RequestPing) XXX_Size() int
- func (m *RequestPing) XXX_Unmarshal(b []byte) error
- type ResponseBroadcastTx
- func (*ResponseBroadcastTx) Descriptor() ([]byte, []int)
- func (this *ResponseBroadcastTx) Equal(that interface{}) bool
- func (m *ResponseBroadcastTx) GetCheckTx() *types.ResponseCheckTx
- func (m *ResponseBroadcastTx) GetDeliverTx() *types.ResponseDeliverTx
- func (m *ResponseBroadcastTx) Marshal() (dAtA []byte, err error)
- func (m *ResponseBroadcastTx) MarshalTo(dAtA []byte) (int, error)
- func (*ResponseBroadcastTx) ProtoMessage()
- func (m *ResponseBroadcastTx) Reset()
- func (m *ResponseBroadcastTx) Size() (n int)
- func (m *ResponseBroadcastTx) String() string
- func (m *ResponseBroadcastTx) Unmarshal(dAtA []byte) error
- func (m *ResponseBroadcastTx) XXX_DiscardUnknown()
- func (m *ResponseBroadcastTx) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ResponseBroadcastTx) XXX_Merge(src proto.Message)
- func (m *ResponseBroadcastTx) XXX_Size() int
- func (m *ResponseBroadcastTx) XXX_Unmarshal(b []byte) error
- type ResponsePing
- func (*ResponsePing) Descriptor() ([]byte, []int)
- func (this *ResponsePing) Equal(that interface{}) bool
- func (m *ResponsePing) Marshal() (dAtA []byte, err error)
- func (m *ResponsePing) MarshalTo(dAtA []byte) (int, error)
- func (*ResponsePing) ProtoMessage()
- func (m *ResponsePing) Reset()
- func (m *ResponsePing) Size() (n int)
- func (m *ResponsePing) String() string
- func (m *ResponsePing) Unmarshal(dAtA []byte) error
- func (m *ResponsePing) XXX_DiscardUnknown()
- func (m *ResponsePing) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ResponsePing) XXX_Merge(src proto.Message)
- func (m *ResponsePing) XXX_Size() int
- func (m *ResponsePing) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTypes = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterBroadcastAPIServer ¶
func RegisterBroadcastAPIServer(s *grpc.Server, srv BroadcastAPIServer)
func StartGRPCServer ¶
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.
Types ¶
type BroadcastAPIClient ¶
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 ¶
func NewBroadcastAPIClient(cc *grpc.ClientConn) BroadcastAPIClient
func StartGRPCClient ¶
func StartGRPCClient(protoAddr string) BroadcastAPIClient
StartGRPCClient dials the gRPC server using protoAddr and returns a new BroadcastAPIClient.
type BroadcastAPIServer ¶
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 ¶ added in v0.22.0
type Config struct {
MaxOpenConnections int
}
Config is an gRPC server configuration.
type RequestBroadcastTx ¶
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 ¶ added in v0.22.5
func NewPopulatedRequestBroadcastTx(r randyTypes, easy bool) *RequestBroadcastTx
func (*RequestBroadcastTx) Descriptor ¶
func (*RequestBroadcastTx) Descriptor() ([]byte, []int)
func (*RequestBroadcastTx) Equal ¶ added in v0.22.5
func (this *RequestBroadcastTx) Equal(that interface{}) bool
func (*RequestBroadcastTx) GetTx ¶
func (m *RequestBroadcastTx) GetTx() []byte
func (*RequestBroadcastTx) Marshal ¶ added in v0.22.5
func (m *RequestBroadcastTx) Marshal() (dAtA []byte, err error)
func (*RequestBroadcastTx) MarshalTo ¶ added in v0.22.5
func (m *RequestBroadcastTx) MarshalTo(dAtA []byte) (int, error)
func (*RequestBroadcastTx) ProtoMessage ¶
func (*RequestBroadcastTx) ProtoMessage()
func (*RequestBroadcastTx) Reset ¶
func (m *RequestBroadcastTx) Reset()
func (*RequestBroadcastTx) Size ¶ added in v0.22.5
func (m *RequestBroadcastTx) Size() (n int)
func (*RequestBroadcastTx) String ¶
func (m *RequestBroadcastTx) String() string
func (*RequestBroadcastTx) Unmarshal ¶ added in v0.22.5
func (m *RequestBroadcastTx) Unmarshal(dAtA []byte) error
func (*RequestBroadcastTx) XXX_DiscardUnknown ¶ added in v0.24.0
func (m *RequestBroadcastTx) XXX_DiscardUnknown()
func (*RequestBroadcastTx) XXX_Marshal ¶ added in v0.24.0
func (m *RequestBroadcastTx) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequestBroadcastTx) XXX_Merge ¶ added in v0.24.0
func (dst *RequestBroadcastTx) XXX_Merge(src proto.Message)
func (*RequestBroadcastTx) XXX_Size ¶ added in v0.24.0
func (m *RequestBroadcastTx) XXX_Size() int
func (*RequestBroadcastTx) XXX_Unmarshal ¶ added in v0.24.0
func (m *RequestBroadcastTx) XXX_Unmarshal(b []byte) error
type RequestPing ¶ added in v0.13.0
type RequestPing struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedRequestPing ¶ added in v0.22.5
func NewPopulatedRequestPing(r randyTypes, easy bool) *RequestPing
func (*RequestPing) Descriptor ¶ added in v0.13.0
func (*RequestPing) Descriptor() ([]byte, []int)
func (*RequestPing) Equal ¶ added in v0.22.5
func (this *RequestPing) Equal(that interface{}) bool
func (*RequestPing) Marshal ¶ added in v0.22.5
func (m *RequestPing) Marshal() (dAtA []byte, err error)
func (*RequestPing) MarshalTo ¶ added in v0.22.5
func (m *RequestPing) MarshalTo(dAtA []byte) (int, error)
func (*RequestPing) ProtoMessage ¶ added in v0.13.0
func (*RequestPing) ProtoMessage()
func (*RequestPing) Reset ¶ added in v0.13.0
func (m *RequestPing) Reset()
func (*RequestPing) Size ¶ added in v0.22.5
func (m *RequestPing) Size() (n int)
func (*RequestPing) String ¶ added in v0.13.0
func (m *RequestPing) String() string
func (*RequestPing) Unmarshal ¶ added in v0.22.5
func (m *RequestPing) Unmarshal(dAtA []byte) error
func (*RequestPing) XXX_DiscardUnknown ¶ added in v0.24.0
func (m *RequestPing) XXX_DiscardUnknown()
func (*RequestPing) XXX_Marshal ¶ added in v0.24.0
func (m *RequestPing) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequestPing) XXX_Merge ¶ added in v0.24.0
func (dst *RequestPing) XXX_Merge(src proto.Message)
func (*RequestPing) XXX_Size ¶ added in v0.24.0
func (m *RequestPing) XXX_Size() int
func (*RequestPing) XXX_Unmarshal ¶ added in v0.24.0
func (m *RequestPing) XXX_Unmarshal(b []byte) error
type ResponseBroadcastTx ¶
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 ¶ added in v0.22.5
func NewPopulatedResponseBroadcastTx(r randyTypes, easy bool) *ResponseBroadcastTx
func (*ResponseBroadcastTx) Descriptor ¶
func (*ResponseBroadcastTx) Descriptor() ([]byte, []int)
func (*ResponseBroadcastTx) Equal ¶ added in v0.22.5
func (this *ResponseBroadcastTx) Equal(that interface{}) bool
func (*ResponseBroadcastTx) GetCheckTx ¶
func (m *ResponseBroadcastTx) GetCheckTx() *types.ResponseCheckTx
func (*ResponseBroadcastTx) GetDeliverTx ¶
func (m *ResponseBroadcastTx) GetDeliverTx() *types.ResponseDeliverTx
func (*ResponseBroadcastTx) Marshal ¶ added in v0.22.5
func (m *ResponseBroadcastTx) Marshal() (dAtA []byte, err error)
func (*ResponseBroadcastTx) MarshalTo ¶ added in v0.22.5
func (m *ResponseBroadcastTx) MarshalTo(dAtA []byte) (int, error)
func (*ResponseBroadcastTx) ProtoMessage ¶
func (*ResponseBroadcastTx) ProtoMessage()
func (*ResponseBroadcastTx) Reset ¶
func (m *ResponseBroadcastTx) Reset()
func (*ResponseBroadcastTx) Size ¶ added in v0.22.5
func (m *ResponseBroadcastTx) Size() (n int)
func (*ResponseBroadcastTx) String ¶
func (m *ResponseBroadcastTx) String() string
func (*ResponseBroadcastTx) Unmarshal ¶ added in v0.22.5
func (m *ResponseBroadcastTx) Unmarshal(dAtA []byte) error
func (*ResponseBroadcastTx) XXX_DiscardUnknown ¶ added in v0.24.0
func (m *ResponseBroadcastTx) XXX_DiscardUnknown()
func (*ResponseBroadcastTx) XXX_Marshal ¶ added in v0.24.0
func (m *ResponseBroadcastTx) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResponseBroadcastTx) XXX_Merge ¶ added in v0.24.0
func (dst *ResponseBroadcastTx) XXX_Merge(src proto.Message)
func (*ResponseBroadcastTx) XXX_Size ¶ added in v0.24.0
func (m *ResponseBroadcastTx) XXX_Size() int
func (*ResponseBroadcastTx) XXX_Unmarshal ¶ added in v0.24.0
func (m *ResponseBroadcastTx) XXX_Unmarshal(b []byte) error
type ResponsePing ¶ added in v0.13.0
type ResponsePing struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedResponsePing ¶ added in v0.22.5
func NewPopulatedResponsePing(r randyTypes, easy bool) *ResponsePing
func (*ResponsePing) Descriptor ¶ added in v0.13.0
func (*ResponsePing) Descriptor() ([]byte, []int)
func (*ResponsePing) Equal ¶ added in v0.22.5
func (this *ResponsePing) Equal(that interface{}) bool
func (*ResponsePing) Marshal ¶ added in v0.22.5
func (m *ResponsePing) Marshal() (dAtA []byte, err error)
func (*ResponsePing) MarshalTo ¶ added in v0.22.5
func (m *ResponsePing) MarshalTo(dAtA []byte) (int, error)
func (*ResponsePing) ProtoMessage ¶ added in v0.13.0
func (*ResponsePing) ProtoMessage()
func (*ResponsePing) Reset ¶ added in v0.13.0
func (m *ResponsePing) Reset()
func (*ResponsePing) Size ¶ added in v0.22.5
func (m *ResponsePing) Size() (n int)
func (*ResponsePing) String ¶ added in v0.13.0
func (m *ResponsePing) String() string
func (*ResponsePing) Unmarshal ¶ added in v0.22.5
func (m *ResponsePing) Unmarshal(dAtA []byte) error
func (*ResponsePing) XXX_DiscardUnknown ¶ added in v0.24.0
func (m *ResponsePing) XXX_DiscardUnknown()
func (*ResponsePing) XXX_Marshal ¶ added in v0.24.0
func (m *ResponsePing) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResponsePing) XXX_Merge ¶ added in v0.24.0
func (dst *ResponsePing) XXX_Merge(src proto.Message)
func (*ResponsePing) XXX_Size ¶ added in v0.24.0
func (m *ResponsePing) XXX_Size() int
func (*ResponsePing) XXX_Unmarshal ¶ added in v0.24.0
func (m *ResponsePing) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.