pbscribe

package
v0.12.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 14, 2024 License: MIT Imports: 20 Imported by: 2

Documentation

Overview

Package pbscribe is the gRPC service definition for the scribe service.

Package pbscribe is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	HealthCheckResponse_ServingStatus_name = map[int32]string{
		0: "UNKNOWN",
		1: "SERVING",
		2: "NOT_SERVING",
		3: "SERVICE_UNKNOWN",
	}
	HealthCheckResponse_ServingStatus_value = map[string]int32{
		"UNKNOWN":         0,
		"SERVING":         1,
		"NOT_SERVING":     2,
		"SERVICE_UNKNOWN": 3,
	}
)

Enum value maps for HealthCheckResponse_ServingStatus.

View Source 
var File_types_v1_filter_proto protoreflect.FileDescriptor
View Source 
var File_types_v1_log_proto protoreflect.FileDescriptor
View Source 
var File_types_v1_service_proto protoreflect.FileDescriptor
View Source 
var File_types_v1_types_proto protoreflect.FileDescriptor
View Source 
var ScribeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "types.v1.ScribeService",
	HandlerType: (*ScribeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Check",
			Handler:    _ScribeService_Check_Handler,
		},
		{
			MethodName: "FilterLogs",
			Handler:    _ScribeService_FilterLogs_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Watch",
			Handler:       _ScribeService_Watch_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamLogs",
			Handler:       _ScribeService_StreamLogs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "types/v1/service.proto",
}

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

Functions

func RegisterScribeServiceHandler 

func RegisterScribeServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterScribeServiceHandler registers the http handlers for service ScribeService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterScribeServiceHandlerClient 

func RegisterScribeServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ScribeServiceClient) error

RegisterScribeServiceHandlerClient registers the http handlers for service ScribeService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ScribeServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ScribeServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ScribeServiceClient" to call the correct interceptors.

func RegisterScribeServiceHandlerFromEndpoint 

func RegisterScribeServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterScribeServiceHandlerFromEndpoint is same as RegisterScribeServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterScribeServiceHandlerServer 

func RegisterScribeServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ScribeServiceServer) error

RegisterScribeServiceHandlerServer registers the http handlers for service ScribeService to "mux". UnaryRPC :call ScribeServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterScribeServiceHandlerFromEndpoint instead.

func RegisterScribeServiceServer 

func RegisterScribeServiceServer(s grpc.ServiceRegistrar, srv ScribeServiceServer)

func ToNativeHashes 

func ToNativeHashes(hashes []*Hash) (nativeHashes []common.Hash)

ToNativeHashes is a helper function for converting a slice of hashes to a native hash array.

func ToNativeLogs 

func ToNativeLogs(logs []*Log) (res []*types.Log)

ToNativeLogs is a helper function for converting logs to native logs.

Types

type Address 

type Address struct {
	Bytes []byte `protobuf:"bytes,1,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// contains filtered or unexported fields
}

func FromNativeAddress 

func FromNativeAddress(address common.Address) *Address

FromNativeAddress converts a native address to a generated address.

func (*Address) Descriptor deprecated 

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

Deprecated: Use Address.ProtoReflect.Descriptor instead.

func (*Address) GetBytes 

func (x *Address) GetBytes() []byte

func (*Address) ProtoMessage 

func (*Address) ProtoMessage()

func (*Address) ProtoReflect 

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

func (*Address) Reset 

func (x *Address) Reset()

func (*Address) String 

func (x *Address) String() string

func (*Address) ToAddress 

func (x *Address) ToAddress() common.Address

ToAddress converts a byte to an address.

type BigInt 

type BigInt struct {
	Bytes []byte `protobuf:"bytes,1,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*BigInt) Descriptor deprecated 

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

Deprecated: Use BigInt.ProtoReflect.Descriptor instead.

func (*BigInt) GetBytes 

func (x *BigInt) GetBytes() []byte

func (*BigInt) ProtoMessage 

func (*BigInt) ProtoMessage()

func (*BigInt) ProtoReflect 

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

func (*BigInt) Reset 

func (x *BigInt) Reset()

func (*BigInt) String 

func (x *BigInt) String() string

type FilterLogsRequest 

type FilterLogsRequest struct {
	Filter *LogFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	Page   uint32     `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterLogsRequest) Descriptor deprecated 

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

Deprecated: Use FilterLogsRequest.ProtoReflect.Descriptor instead.

func (*FilterLogsRequest) GetFilter 

func (x *FilterLogsRequest) GetFilter() *LogFilter

func (*FilterLogsRequest) GetPage 

func (x *FilterLogsRequest) GetPage() uint32

func (*FilterLogsRequest) ProtoMessage 

func (*FilterLogsRequest) ProtoMessage()

func (*FilterLogsRequest) ProtoReflect 

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

func (*FilterLogsRequest) Reset 

func (x *FilterLogsRequest) Reset()

func (*FilterLogsRequest) String 

func (x *FilterLogsRequest) String() string

type FilterLogsResponse 

type FilterLogsResponse struct {
	Logs []*Log `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterLogsResponse) Descriptor deprecated 

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

Deprecated: Use FilterLogsResponse.ProtoReflect.Descriptor instead.

func (*FilterLogsResponse) GetLogs 

func (x *FilterLogsResponse) GetLogs() []*Log

func (*FilterLogsResponse) ProtoMessage 

func (*FilterLogsResponse) ProtoMessage()

func (*FilterLogsResponse) ProtoReflect 

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

func (*FilterLogsResponse) Reset 

func (x *FilterLogsResponse) Reset()

func (*FilterLogsResponse) String 

func (x *FilterLogsResponse) String() string

type Hash 

type Hash struct {
	Bytes []byte `protobuf:"bytes,1,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// contains filtered or unexported fields
}

func FromNativeHash 

func FromNativeHash(nativeHash common.Hash) *Hash

FromNativeHash converts an eth hash to a bytes hash.

func FromNativeHashes 

func FromNativeHashes(nativeHashes []common.Hash) (castHashes []*Hash)

FromNativeHashes is a helper function for converting a slice of native hashes to a hash array.

func (*Hash) Descriptor deprecated 

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

Deprecated: Use Hash.ProtoReflect.Descriptor instead.

func (*Hash) GetBytes 

func (x *Hash) GetBytes() []byte

func (*Hash) ProtoMessage 

func (*Hash) ProtoMessage()

func (*Hash) ProtoReflect 

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

func (*Hash) Reset 

func (x *Hash) Reset()

func (*Hash) String 

func (x *Hash) String() string

func (*Hash) ToHash 

func (x *Hash) ToHash() common.Hash

ToHash converts a native hash to a hash list.

type HealthCheckRequest 

type HealthCheckRequest struct {
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckRequest) Descriptor deprecated 

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

Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.

func (*HealthCheckRequest) GetService 

func (x *HealthCheckRequest) GetService() string

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect 

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

func (*HealthCheckRequest) Reset 

func (x *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String 

func (x *HealthCheckRequest) String() string

type HealthCheckResponse 

type HealthCheckResponse struct {
	Status HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=types.v1.HealthCheckResponse_ServingStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckResponse) Descriptor deprecated 

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

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) GetStatus 

func (x *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect 

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

func (*HealthCheckResponse) Reset 

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (x *HealthCheckResponse) String() string

type HealthCheckResponse_ServingStatus 

type HealthCheckResponse_ServingStatus int32
const (
	HealthCheckResponse_UNKNOWN         HealthCheckResponse_ServingStatus = 0
	HealthCheckResponse_SERVING         HealthCheckResponse_ServingStatus = 1
	HealthCheckResponse_NOT_SERVING     HealthCheckResponse_ServingStatus = 2
	HealthCheckResponse_SERVICE_UNKNOWN HealthCheckResponse_ServingStatus = 3 // Used only by the Watch method.
)

func (HealthCheckResponse_ServingStatus) Descriptor 

func (HealthCheckResponse_ServingStatus) Descriptor() protoreflect.EnumDescriptor

func (HealthCheckResponse_ServingStatus) Enum 

func (x HealthCheckResponse_ServingStatus) Enum() *HealthCheckResponse_ServingStatus

func (HealthCheckResponse_ServingStatus) EnumDescriptor deprecated 

func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use HealthCheckResponse_ServingStatus.Descriptor instead.

func (HealthCheckResponse_ServingStatus) Number 

func (x HealthCheckResponse_ServingStatus) Number() protoreflect.EnumNumber

func (HealthCheckResponse_ServingStatus) String 

func (x HealthCheckResponse_ServingStatus) String() string

func (HealthCheckResponse_ServingStatus) Type 

func (HealthCheckResponse_ServingStatus) Type() protoreflect.EnumType

type Log 

type Log struct {
	Address     *Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Topics      []*Hash  `protobuf:"bytes,2,rep,name=topics,proto3" json:"topics,omitempty"`
	Data        []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	BlockNumber uint64   `protobuf:"varint,4,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
	TxHash      *Hash    `protobuf:"bytes,5,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	TxIndex     uint64   `protobuf:"varint,6,opt,name=tx_index,json=txIndex,proto3" json:"tx_index,omitempty"`
	BlockHash   *Hash    `protobuf:"bytes,7,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	Index       uint64   `protobuf:"varint,8,opt,name=index,proto3" json:"index,omitempty"`
	Removed     bool     `protobuf:"varint,9,opt,name=removed,proto3" json:"removed,omitempty"`
	// contains filtered or unexported fields
}

func FromNativeLog 

func FromNativeLog(log *types.Log) *Log

FromNativeLog converts a native log to a proto log.

func FromNativeLogs 

func FromNativeLogs(logs []*types.Log) (res []*Log)

FromNativeLogs is a helper function for converting a batch of logs all at once.

func (*Log) Descriptor deprecated 

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetAddress 

func (x *Log) GetAddress() *Address

func (*Log) GetBlockHash 

func (x *Log) GetBlockHash() *Hash

func (*Log) GetBlockNumber 

func (x *Log) GetBlockNumber() uint64

func (*Log) GetData 

func (x *Log) GetData() []byte

func (*Log) GetIndex 

func (x *Log) GetIndex() uint64

func (*Log) GetRemoved 

func (x *Log) GetRemoved() bool

func (*Log) GetTopics 

func (x *Log) GetTopics() []*Hash

func (*Log) GetTxHash 

func (x *Log) GetTxHash() *Hash

func (*Log) GetTxIndex 

func (x *Log) GetTxIndex() uint64

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) ProtoReflect 

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

func (*Log) Reset 

func (x *Log) Reset()

func (*Log) String 

func (x *Log) String() string

func (*Log) ToLog 

func (x *Log) ToLog() *types.Log

ToLog converts a log type to a native log.

type LogFilter 

type LogFilter struct {
	ContractAddress *NullableString `protobuf:"bytes,1,opt,name=contract_address,json=contractAddress,proto3" json:"contract_address,omitempty"`
	ChainId         uint32          `protobuf:"varint,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	BlockNumber     *NullableUint64 `protobuf:"bytes,3,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
	TxHash          *NullableString `protobuf:"bytes,4,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	TxIndex         *NullableUint64 `protobuf:"bytes,5,opt,name=tx_index,json=txIndex,proto3" json:"tx_index,omitempty"`
	BlockHash       *NullableString `protobuf:"bytes,6,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	Index           *NullableUint64 `protobuf:"bytes,7,opt,name=index,proto3" json:"index,omitempty"`
	Confirmed       *NullableBool   `protobuf:"bytes,8,opt,name=confirmed,proto3" json:"confirmed,omitempty"`
	// contains filtered or unexported fields
}

func (*LogFilter) Descriptor deprecated 

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

Deprecated: Use LogFilter.ProtoReflect.Descriptor instead.

func (*LogFilter) GetBlockHash 

func (x *LogFilter) GetBlockHash() *NullableString

func (*LogFilter) GetBlockNumber 

func (x *LogFilter) GetBlockNumber() *NullableUint64

func (*LogFilter) GetChainId 

func (x *LogFilter) GetChainId() uint32

func (*LogFilter) GetConfirmed 

func (x *LogFilter) GetConfirmed() *NullableBool

func (*LogFilter) GetContractAddress 

func (x *LogFilter) GetContractAddress() *NullableString

func (*LogFilter) GetIndex 

func (x *LogFilter) GetIndex() *NullableUint64

func (*LogFilter) GetTxHash 

func (x *LogFilter) GetTxHash() *NullableString

func (*LogFilter) GetTxIndex 

func (x *LogFilter) GetTxIndex() *NullableUint64

func (*LogFilter) ProtoMessage 

func (*LogFilter) ProtoMessage()

func (*LogFilter) ProtoReflect 

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

func (*LogFilter) Reset 

func (x *LogFilter) Reset()

func (*LogFilter) String 

func (x *LogFilter) String() string

func (*LogFilter) ToNative 

func (x *LogFilter) ToNative() db.LogFilter

ToNative converts the log filter to native.

type NullableBool 

type NullableBool struct {

	// Types that are assignable to Kind:
	//
	//	*NullableBool_Null
	//	*NullableBool_Data
	Kind isNullableBool_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*NullableBool) Descriptor deprecated 

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

Deprecated: Use NullableBool.ProtoReflect.Descriptor instead.

func (*NullableBool) GetData 

func (x *NullableBool) GetData() bool

func (*NullableBool) GetKind 

func (m *NullableBool) GetKind() isNullableBool_Kind

func (*NullableBool) GetNull 

func (x *NullableBool) GetNull() structpb.NullValue

func (*NullableBool) ProtoMessage 

func (*NullableBool) ProtoMessage()

func (*NullableBool) ProtoReflect 

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

func (*NullableBool) Reset 

func (x *NullableBool) Reset()

func (*NullableBool) String 

func (x *NullableBool) String() string

type NullableBool_Data 

type NullableBool_Data struct {
	Data bool `protobuf:"varint,2,opt,name=data,proto3,oneof"`
}

type NullableBool_Null 

type NullableBool_Null struct {
	Null structpb.NullValue `protobuf:"varint,1,opt,name=null,proto3,enum=google.protobuf.NullValue,oneof"`
}

type NullableString 

type NullableString struct {

	// Types that are assignable to Kind:
	//
	//	*NullableString_Null
	//	*NullableString_Data
	Kind isNullableString_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*NullableString) Descriptor deprecated 

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

Deprecated: Use NullableString.ProtoReflect.Descriptor instead.

func (*NullableString) GetData 

func (x *NullableString) GetData() string

func (*NullableString) GetKind 

func (m *NullableString) GetKind() isNullableString_Kind

func (*NullableString) GetNull 

func (x *NullableString) GetNull() structpb.NullValue

func (*NullableString) ProtoMessage 

func (*NullableString) ProtoMessage()

func (*NullableString) ProtoReflect 

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

func (*NullableString) Reset 

func (x *NullableString) Reset()

func (*NullableString) String 

func (x *NullableString) String() string

type NullableString_Data 

type NullableString_Data struct {
	Data string `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type NullableString_Null 

type NullableString_Null struct {
	Null structpb.NullValue `protobuf:"varint,1,opt,name=null,proto3,enum=google.protobuf.NullValue,oneof"`
}

type NullableUint32 

type NullableUint32 struct {

	// Types that are assignable to Kind:
	//
	//	*NullableUint32_Null
	//	*NullableUint32_Data
	Kind isNullableUint32_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*NullableUint32) Descriptor deprecated 

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

Deprecated: Use NullableUint32.ProtoReflect.Descriptor instead.

func (*NullableUint32) GetData 

func (x *NullableUint32) GetData() uint32

func (*NullableUint32) GetKind 

func (m *NullableUint32) GetKind() isNullableUint32_Kind

func (*NullableUint32) GetNull 

func (x *NullableUint32) GetNull() structpb.NullValue

func (*NullableUint32) ProtoMessage 

func (*NullableUint32) ProtoMessage()

func (*NullableUint32) ProtoReflect 

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

func (*NullableUint32) Reset 

func (x *NullableUint32) Reset()

func (*NullableUint32) String 

func (x *NullableUint32) String() string

type NullableUint32_Data 

type NullableUint32_Data struct {
	Data uint32 `protobuf:"varint,2,opt,name=data,proto3,oneof"`
}

type NullableUint32_Null 

type NullableUint32_Null struct {
	Null structpb.NullValue `protobuf:"varint,1,opt,name=null,proto3,enum=google.protobuf.NullValue,oneof"`
}

type NullableUint64 

type NullableUint64 struct {

	// Types that are assignable to Kind:
	//
	//	*NullableUint64_Null
	//	*NullableUint64_Data
	Kind isNullableUint64_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*NullableUint64) Descriptor deprecated 

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

Deprecated: Use NullableUint64.ProtoReflect.Descriptor instead.

func (*NullableUint64) GetData 

func (x *NullableUint64) GetData() uint64

func (*NullableUint64) GetKind 

func (m *NullableUint64) GetKind() isNullableUint64_Kind

func (*NullableUint64) GetNull 

func (x *NullableUint64) GetNull() structpb.NullValue

func (*NullableUint64) ProtoMessage 

func (*NullableUint64) ProtoMessage()

func (*NullableUint64) ProtoReflect 

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

func (*NullableUint64) Reset 

func (x *NullableUint64) Reset()

func (*NullableUint64) String 

func (x *NullableUint64) String() string

type NullableUint64_Data 

type NullableUint64_Data struct {
	Data uint64 `protobuf:"varint,2,opt,name=data,proto3,oneof"`
}

type NullableUint64_Null 

type NullableUint64_Null struct {
	Null structpb.NullValue `protobuf:"varint,1,opt,name=null,proto3,enum=google.protobuf.NullValue,oneof"`
}

type ScribeServiceClient 

type ScribeServiceClient interface {
	// see: https://github.com/grpc/grpc/blob/master/doc/health-checking.md
	Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	Watch(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (ScribeService_WatchClient, error)
	FilterLogs(ctx context.Context, in *FilterLogsRequest, opts ...grpc.CallOption) (*FilterLogsResponse, error)
	StreamLogs(ctx context.Context, in *StreamLogsRequest, opts ...grpc.CallOption) (ScribeService_StreamLogsClient, error)
}

ScribeServiceClient is the client API for ScribeService 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 NewScribeServiceClient 

func NewScribeServiceClient(cc grpc.ClientConnInterface) ScribeServiceClient

type ScribeServiceServer 

type ScribeServiceServer interface {
	// see: https://github.com/grpc/grpc/blob/master/doc/health-checking.md
	Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	Watch(*HealthCheckRequest, ScribeService_WatchServer) error
	FilterLogs(context.Context, *FilterLogsRequest) (*FilterLogsResponse, error)
	StreamLogs(*StreamLogsRequest, ScribeService_StreamLogsServer) error
	// contains filtered or unexported methods
}

ScribeServiceServer is the server API for ScribeService service. All implementations must embed UnimplementedScribeServiceServer for forward compatibility

type ScribeService_StreamLogsClient added in v0.0.73 

type ScribeService_StreamLogsClient interface {
	Recv() (*StreamLogsResponse, error)
	grpc.ClientStream
}

type ScribeService_StreamLogsServer added in v0.0.73 

type ScribeService_StreamLogsServer interface {
	Send(*StreamLogsResponse) error
	grpc.ServerStream
}

type ScribeService_WatchClient 

type ScribeService_WatchClient interface {
	Recv() (*HealthCheckResponse, error)
	grpc.ClientStream
}

type ScribeService_WatchServer 

type ScribeService_WatchServer interface {
	Send(*HealthCheckResponse) error
	grpc.ServerStream
}

type StreamLogsRequest added in v0.0.73 

type StreamLogsRequest struct {
	Filter    *LogFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	FromBlock string     `protobuf:"bytes,2,opt,name=fromBlock,proto3" json:"fromBlock,omitempty"`
	ToBlock   string     `protobuf:"bytes,3,opt,name=toBlock,proto3" json:"toBlock,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamLogsRequest) Descriptor deprecated added in v0.0.73 

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

Deprecated: Use StreamLogsRequest.ProtoReflect.Descriptor instead.

func (*StreamLogsRequest) GetFilter added in v0.0.73 

func (x *StreamLogsRequest) GetFilter() *LogFilter

func (*StreamLogsRequest) GetFromBlock added in v0.0.73 

func (x *StreamLogsRequest) GetFromBlock() string

func (*StreamLogsRequest) GetToBlock added in v0.0.73 

func (x *StreamLogsRequest) GetToBlock() string

func (*StreamLogsRequest) ProtoMessage added in v0.0.73 

func (*StreamLogsRequest) ProtoMessage()

func (*StreamLogsRequest) ProtoReflect added in v0.0.73 

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

func (*StreamLogsRequest) Reset added in v0.0.73 

func (x *StreamLogsRequest) Reset()

func (*StreamLogsRequest) String added in v0.0.73 

func (x *StreamLogsRequest) String() string

type StreamLogsResponse added in v0.0.73 

type StreamLogsResponse struct {
	Log *Log `protobuf:"bytes,1,opt,name=log,proto3" json:"log,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamLogsResponse) Descriptor deprecated added in v0.0.73 

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

Deprecated: Use StreamLogsResponse.ProtoReflect.Descriptor instead.

func (*StreamLogsResponse) GetLog added in v0.0.73 

func (x *StreamLogsResponse) GetLog() *Log

func (*StreamLogsResponse) ProtoMessage added in v0.0.73 

func (*StreamLogsResponse) ProtoMessage()

func (*StreamLogsResponse) ProtoReflect added in v0.0.73 

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

func (*StreamLogsResponse) Reset added in v0.0.73 

func (x *StreamLogsResponse) Reset()

func (*StreamLogsResponse) String added in v0.0.73 

func (x *StreamLogsResponse) String() string

type UnimplementedScribeServiceServer 

type UnimplementedScribeServiceServer struct {
}

UnimplementedScribeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedScribeServiceServer) Check 

func (UnimplementedScribeServiceServer) Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)

func (UnimplementedScribeServiceServer) FilterLogs 

func (UnimplementedScribeServiceServer) FilterLogs(context.Context, *FilterLogsRequest) (*FilterLogsResponse, error)

func (UnimplementedScribeServiceServer) StreamLogs added in v0.0.73 

func (UnimplementedScribeServiceServer) StreamLogs(*StreamLogsRequest, ScribeService_StreamLogsServer) error

func (UnimplementedScribeServiceServer) Watch 

func (UnimplementedScribeServiceServer) Watch(*HealthCheckRequest, ScribeService_WatchServer) error

type UnsafeScribeServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.