Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var File_sentinel_proto protoreflect.FileDescriptor
var Sentinel_ServiceDesc = grpc.ServiceDesc{ ServiceName: "sentinel.Sentinel", HandlerType: (*SentinelServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Publish", Handler: _Sentinel_Publish_Handler, }, { MethodName: "GetHeadCID", Handler: _Sentinel_GetHeadCID_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "sentinel.proto", }
Sentinel_ServiceDesc is the grpc.ServiceDesc for Sentinel service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSentinelServer ¶
func RegisterSentinelServer(s grpc.ServiceRegistrar, srv SentinelServer)
Types ¶
type GetHeadCIDRequest ¶
type GetHeadCIDRequest struct {
// contains filtered or unexported fields
}
func (*GetHeadCIDRequest) Descriptor
deprecated
func (*GetHeadCIDRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetHeadCIDRequest.ProtoReflect.Descriptor instead.
func (*GetHeadCIDRequest) ProtoMessage ¶
func (*GetHeadCIDRequest) ProtoMessage()
func (*GetHeadCIDRequest) ProtoReflect ¶
func (x *GetHeadCIDRequest) ProtoReflect() protoreflect.Message
func (*GetHeadCIDRequest) Reset ¶
func (x *GetHeadCIDRequest) Reset()
func (*GetHeadCIDRequest) String ¶
func (x *GetHeadCIDRequest) String() string
type GetHeadCIDResponse ¶
type GetHeadCIDResponse struct {
Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
// contains filtered or unexported fields
}
func (*GetHeadCIDResponse) Descriptor
deprecated
func (*GetHeadCIDResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetHeadCIDResponse.ProtoReflect.Descriptor instead.
func (*GetHeadCIDResponse) GetCid ¶
func (x *GetHeadCIDResponse) GetCid() string
func (*GetHeadCIDResponse) ProtoMessage ¶
func (*GetHeadCIDResponse) ProtoMessage()
func (*GetHeadCIDResponse) ProtoReflect ¶
func (x *GetHeadCIDResponse) ProtoReflect() protoreflect.Message
func (*GetHeadCIDResponse) Reset ¶
func (x *GetHeadCIDResponse) Reset()
func (*GetHeadCIDResponse) String ¶
func (x *GetHeadCIDResponse) String() string
type PublishRequest ¶
type PublishRequest struct {
Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
// contains filtered or unexported fields
}
func (*PublishRequest) Descriptor
deprecated
func (*PublishRequest) Descriptor() ([]byte, []int)
Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.
func (*PublishRequest) GetCid ¶
func (x *PublishRequest) GetCid() string
func (*PublishRequest) ProtoMessage ¶
func (*PublishRequest) ProtoMessage()
func (*PublishRequest) ProtoReflect ¶
func (x *PublishRequest) ProtoReflect() protoreflect.Message
func (*PublishRequest) Reset ¶
func (x *PublishRequest) Reset()
func (*PublishRequest) String ¶
func (x *PublishRequest) String() string
type PublishResponse ¶
type PublishResponse struct {
// contains filtered or unexported fields
}
func (*PublishResponse) Descriptor
deprecated
func (*PublishResponse) Descriptor() ([]byte, []int)
Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.
func (*PublishResponse) ProtoMessage ¶
func (*PublishResponse) ProtoMessage()
func (*PublishResponse) ProtoReflect ¶
func (x *PublishResponse) ProtoReflect() protoreflect.Message
func (*PublishResponse) Reset ¶
func (x *PublishResponse) Reset()
func (*PublishResponse) String ¶
func (x *PublishResponse) String() string
type SentinelClient ¶
type SentinelClient interface {
Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
// this might be removed when we start to serve topic head via IPNS
GetHeadCID(ctx context.Context, in *GetHeadCIDRequest, opts ...grpc.CallOption) (*GetHeadCIDResponse, error)
}
SentinelClient is the client API for Sentinel 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 NewSentinelClient ¶
func NewSentinelClient(cc grpc.ClientConnInterface) SentinelClient
type SentinelServer ¶
type SentinelServer interface {
Publish(context.Context, *PublishRequest) (*PublishResponse, error)
// this might be removed when we start to serve topic head via IPNS
GetHeadCID(context.Context, *GetHeadCIDRequest) (*GetHeadCIDResponse, error)
// contains filtered or unexported methods
}
SentinelServer is the server API for Sentinel service. All implementations must embed UnimplementedSentinelServer for forward compatibility
type UnimplementedSentinelServer ¶
type UnimplementedSentinelServer struct{}
UnimplementedSentinelServer must be embedded to have forward compatible implementations.
func (UnimplementedSentinelServer) GetHeadCID ¶
func (UnimplementedSentinelServer) GetHeadCID(context.Context, *GetHeadCIDRequest) (*GetHeadCIDResponse, error)
func (UnimplementedSentinelServer) Publish ¶
func (UnimplementedSentinelServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)
type UnsafeSentinelServer ¶
type UnsafeSentinelServer interface {
// contains filtered or unexported methods
}
UnsafeSentinelServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SentinelServer will result in compilation errors.
Source Files