powergate: github.com/textileio/powergate/index/faults/rpc Index | Files

package rpc

import "github.com/textileio/powergate/index/faults/rpc"

Index

Package Files

rpc.go rpc.pb.go

Variables

var File_index_faults_rpc_rpc_proto protoreflect.FileDescriptor

func RegisterRPCServiceServer Uses

func RegisterRPCServiceServer(s *grpc.Server, srv RPCServiceServer)

type Faults Uses

type Faults struct {
    Epochs []int64 `protobuf:"varint,1,rep,packed,name=epochs,proto3" json:"epochs,omitempty"`
    // contains filtered or unexported fields
}

func (*Faults) Descriptor Uses

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

Deprecated: Use Faults.ProtoReflect.Descriptor instead.

func (*Faults) GetEpochs Uses

func (x *Faults) GetEpochs() []int64

func (*Faults) ProtoMessage Uses

func (*Faults) ProtoMessage()

func (*Faults) ProtoReflect Uses

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

func (*Faults) Reset Uses

func (x *Faults) Reset()

func (*Faults) String Uses

func (x *Faults) String() string

type GetRequest Uses

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

func (*GetRequest) Descriptor Uses

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) ProtoMessage Uses

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect Uses

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

func (*GetRequest) Reset Uses

func (x *GetRequest) Reset()

func (*GetRequest) String Uses

func (x *GetRequest) String() string

type GetResponse Uses

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

func (*GetResponse) Descriptor Uses

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetIndex Uses

func (x *GetResponse) GetIndex() *Index

func (*GetResponse) ProtoMessage Uses

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect Uses

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

func (*GetResponse) Reset Uses

func (x *GetResponse) Reset()

func (*GetResponse) String Uses

func (x *GetResponse) String() string

type Index Uses

type Index struct {
    Tipsetkey string             `protobuf:"bytes,1,opt,name=tipsetkey,proto3" json:"tipsetkey,omitempty"`
    Miners    map[string]*Faults `protobuf:"bytes,2,rep,name=miners,proto3" json:"miners,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // contains filtered or unexported fields
}

func (*Index) Descriptor Uses

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

Deprecated: Use Index.ProtoReflect.Descriptor instead.

func (*Index) GetMiners Uses

func (x *Index) GetMiners() map[string]*Faults

func (*Index) GetTipsetkey Uses

func (x *Index) GetTipsetkey() string

func (*Index) ProtoMessage Uses

func (*Index) ProtoMessage()

func (*Index) ProtoReflect Uses

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

func (*Index) Reset Uses

func (x *Index) Reset()

func (*Index) String Uses

func (x *Index) String() string

type RPC Uses

type RPC struct {
    UnimplementedRPCServiceServer
    // contains filtered or unexported fields
}

RPC implements the gprc service.

func New Uses

func New(fi faults.Module) *RPC

New creates a new rpc service.

func (*RPC) Get Uses

func (s *RPC) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

Get calls faults index Get.

type RPCServiceClient Uses

type RPCServiceClient interface {
    Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
}

RPCServiceClient is the client API for RPCService service.

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

func NewRPCServiceClient Uses

func NewRPCServiceClient(cc grpc.ClientConnInterface) RPCServiceClient

type RPCServiceServer Uses

type RPCServiceServer interface {
    Get(context.Context, *GetRequest) (*GetResponse, error)
}

RPCServiceServer is the server API for RPCService service.

type UnimplementedRPCServiceServer Uses

type UnimplementedRPCServiceServer struct {
}

UnimplementedRPCServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRPCServiceServer) Get Uses

func (*UnimplementedRPCServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error)

Package rpc imports 10 packages (graph) and is imported by 5 packages. Updated 2020-09-21. Refresh now. Tools for package owners.