pbtrxstream

Documentation

Index

• Variables
• func RegisterTransactionStreamServer(s grpc.ServiceRegistrar, srv TransactionStreamServer)
• type TransactionRequest
  • func (*TransactionRequest) Descriptor() ([]byte, []int)
  • func (*TransactionRequest) ProtoMessage()
  • func (x *TransactionRequest) ProtoReflect() protoreflect.Message
  • func (x *TransactionRequest) Reset()
  • func (x *TransactionRequest) String() string
• type TransactionStreamClient
  • func NewTransactionStreamClient(cc grpc.ClientConnInterface) TransactionStreamClient
• type TransactionStreamServer
• type TransactionStream_TransactionsClient
• type TransactionStream_TransactionsServer
• type UnimplementedTransactionStreamServer
  • func (UnimplementedTransactionStreamServer) Transactions(*TransactionRequest, TransactionStream_TransactionsServer) error
• type UnsafeTransactionStreamServer

Variables

var File_sf_ethereum_trxstream_v1_trxstream_proto protoreflect.FileDescriptor

var TransactionStream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sf.ethereum.trxstream.v1.TransactionStream",
	HandlerType: (*TransactionStreamServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Transactions",
			Handler:       _TransactionStream_Transactions_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "sf/ethereum/trxstream/v1/trxstream.proto",
}

TransactionStream_ServiceDesc is the grpc.ServiceDesc for TransactionStream service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTransactionStreamServer

func RegisterTransactionStreamServer(s grpc.ServiceRegistrar, srv TransactionStreamServer)

Types

type TransactionRequest

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

func (*TransactionRequest) Descriptor

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

Deprecated: Use TransactionRequest.ProtoReflect.Descriptor instead.

func (*TransactionRequest) ProtoMessage

func (*TransactionRequest) ProtoMessage()

func (*TransactionRequest) ProtoReflect

func (x *TransactionRequest) ProtoReflect() protoreflect.Message

func (*TransactionRequest) Reset

func (x *TransactionRequest) Reset()

func (*TransactionRequest) String

func (x *TransactionRequest) String() string

type TransactionStreamClient

type TransactionStreamClient interface {
	Transactions(ctx context.Context, in *TransactionRequest, opts ...grpc.CallOption) (TransactionStream_TransactionsClient, error)
}

TransactionStreamClient is the client API for TransactionStream service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTransactionStreamClient

func NewTransactionStreamClient(cc grpc.ClientConnInterface) TransactionStreamClient

type TransactionStreamServer

type TransactionStreamServer interface {
	Transactions(*TransactionRequest, TransactionStream_TransactionsServer) error
}

TransactionStreamServer is the server API for TransactionStream service. All implementations should embed UnimplementedTransactionStreamServer for forward compatibility

type TransactionStream_TransactionsClient

type TransactionStream_TransactionsClient interface {
	Recv() (*v1.Transaction, error)
	grpc.ClientStream
}

type TransactionStream_TransactionsServer

type TransactionStream_TransactionsServer interface {
	Send(*v1.Transaction) error
	grpc.ServerStream
}

type UnimplementedTransactionStreamServer

type UnimplementedTransactionStreamServer struct {
}

UnimplementedTransactionStreamServer should be embedded to have forward compatible implementations.

func (UnimplementedTransactionStreamServer) Transactions

func (UnimplementedTransactionStreamServer) Transactions(*TransactionRequest, TransactionStream_TransactionsServer) error

type UnsafeTransactionStreamServer

type UnsafeTransactionStreamServer interface {
	// contains filtered or unexported methods
}

UnsafeTransactionStreamServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TransactionStreamServer will result in compilation errors.