indexer

Documentation

Index

• Variables
• func RegisterIndexerServiceServer(s *grpc.Server, srv IndexerServiceServer)
• type IndexerServiceClient
  • func NewIndexerServiceClient(cc grpc.ClientConnInterface) IndexerServiceClient
• type IndexerServiceServer
• type IndexerService_TaskRPCClient
• type IndexerService_TaskRPCServer
• type TaskError
  • func (*TaskError) Descriptor() ([]byte, []int)
  • func (x *TaskError) GetMsg() string
  • func (x *TaskError) GetType() string
  • func (*TaskError) ProtoMessage()
  • func (x *TaskError) ProtoReflect() protoreflect.Message
  • func (x *TaskError) Reset()
  • func (x *TaskError) String() string
• type TaskRequest
  • func (*TaskRequest) Descriptor() ([]byte, []int)
  • func (x *TaskRequest) GetFrom() string
  • func (x *TaskRequest) GetId() string
  • func (x *TaskRequest) GetPayload() []byte
  • func (x *TaskRequest) GetType() string
  • func (x *TaskRequest) GetVersion() string
  • func (*TaskRequest) ProtoMessage()
  • func (x *TaskRequest) ProtoReflect() protoreflect.Message
  • func (x *TaskRequest) Reset()
  • func (x *TaskRequest) String() string
• type TaskResponse
  • func (*TaskResponse) Descriptor() ([]byte, []int)
  • func (x *TaskResponse) GetError() *TaskError
  • func (x *TaskResponse) GetFinal() bool
  • func (x *TaskResponse) GetId() string
  • func (x *TaskResponse) GetOrder() int64
  • func (x *TaskResponse) GetPayload() []byte
  • func (x *TaskResponse) GetType() string
  • func (x *TaskResponse) GetVersion() string
  • func (*TaskResponse) ProtoMessage()
  • func (x *TaskResponse) ProtoReflect() protoreflect.Message
  • func (x *TaskResponse) Reset()
  • func (x *TaskResponse) String() string
• type UnimplementedIndexerServiceServer
  • func (*UnimplementedIndexerServiceServer) TaskRPC(IndexerService_TaskRPCServer) error

Variables

var File_proto_indexer_proto protoreflect.FileDescriptor

Functions

func RegisterIndexerServiceServer

func RegisterIndexerServiceServer(s *grpc.Server, srv IndexerServiceServer)

Types

type IndexerServiceClient

type IndexerServiceClient interface {
	TaskRPC(ctx context.Context, opts ...grpc.CallOption) (IndexerService_TaskRPCClient, error)
}

IndexerServiceClient is the client API for IndexerService service.

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

func NewIndexerServiceClient

func NewIndexerServiceClient(cc grpc.ClientConnInterface) IndexerServiceClient

type IndexerServiceServer

type IndexerServiceServer interface {
	TaskRPC(IndexerService_TaskRPCServer) error
}

IndexerServiceServer is the server API for IndexerService service.

type IndexerService_TaskRPCClient

type IndexerService_TaskRPCClient interface {
	Send(*TaskRequest) error
	Recv() (*TaskResponse, error)
	grpc.ClientStream
}

type IndexerService_TaskRPCServer

type IndexerService_TaskRPCServer interface {
	Send(*TaskResponse) error
	Recv() (*TaskRequest, error)
	grpc.ServerStream
}

type TaskError

type TaskError struct {
	Msg  string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskError) Descriptor

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

Deprecated: Use TaskError.ProtoReflect.Descriptor instead.

func (*TaskError) GetMsg

func (x *TaskError) GetMsg() string

func (*TaskError) GetType

func (x *TaskError) GetType() string

func (*TaskError) ProtoMessage

func (*TaskError) ProtoMessage()

func (*TaskError) ProtoReflect

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

func (*TaskError) Reset

func (x *TaskError) Reset()

func (*TaskError) String

func (x *TaskError) String() string

type TaskRequest

type TaskRequest struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Id      string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Type    string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	From    string `protobuf:"bytes,4,opt,name=from,proto3" json:"from,omitempty"`
	Payload []byte `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskRequest) Descriptor

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

Deprecated: Use TaskRequest.ProtoReflect.Descriptor instead.

func (*TaskRequest) GetFrom

func (x *TaskRequest) GetFrom() string

func (*TaskRequest) GetId

func (x *TaskRequest) GetId() string

func (*TaskRequest) GetPayload

func (x *TaskRequest) GetPayload() []byte

func (*TaskRequest) GetType

func (x *TaskRequest) GetType() string

func (*TaskRequest) GetVersion

func (x *TaskRequest) GetVersion() string

func (*TaskRequest) ProtoMessage

func (*TaskRequest) ProtoMessage()

func (*TaskRequest) ProtoReflect

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

func (*TaskRequest) Reset

func (x *TaskRequest) Reset()

func (*TaskRequest) String

func (x *TaskRequest) String() string

type TaskResponse

type TaskResponse struct {
	Version string     `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Id      string     `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Type    string     `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Order   int64      `protobuf:"varint,4,opt,name=order,proto3" json:"order,omitempty"`
	Final   bool       `protobuf:"varint,5,opt,name=final,proto3" json:"final,omitempty"`
	Error   *TaskError `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	Payload []byte     `protobuf:"bytes,7,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskResponse) Descriptor

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

Deprecated: Use TaskResponse.ProtoReflect.Descriptor instead.

func (*TaskResponse) GetError

func (x *TaskResponse) GetError() *TaskError

func (*TaskResponse) GetFinal

func (x *TaskResponse) GetFinal() bool

func (*TaskResponse) GetId

func (x *TaskResponse) GetId() string

func (*TaskResponse) GetOrder

func (x *TaskResponse) GetOrder() int64

func (*TaskResponse) GetPayload

func (x *TaskResponse) GetPayload() []byte

func (*TaskResponse) GetType

func (x *TaskResponse) GetType() string

func (*TaskResponse) GetVersion

func (x *TaskResponse) GetVersion() string

func (*TaskResponse) ProtoMessage

func (*TaskResponse) ProtoMessage()

func (*TaskResponse) ProtoReflect

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

func (*TaskResponse) Reset

func (x *TaskResponse) Reset()

func (*TaskResponse) String

func (x *TaskResponse) String() string

type UnimplementedIndexerServiceServer

type UnimplementedIndexerServiceServer struct {
}

UnimplementedIndexerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedIndexerServiceServer) TaskRPC

func (*UnimplementedIndexerServiceServer) TaskRPC(IndexerService_TaskRPCServer) error