Documentation ¶
Index ¶
- Variables
- func RegisterPublisherServer(s grpc.ServiceRegistrar, srv PublisherServer)
- type Advertisement
- func (*Advertisement) Descriptor() ([]byte, []int)deprecated
- func (x *Advertisement) GetContextId() []byte
- func (x *Advertisement) GetEntries() *Link
- func (x *Advertisement) GetID() *Link
- func (x *Advertisement) GetMetadata() []byte
- func (x *Advertisement) GetRemoved() bool
- func (*Advertisement) ProtoMessage()
- func (x *Advertisement) ProtoReflect() protoreflect.Message
- func (x *Advertisement) Reset()
- func (x *Advertisement) String() string
- type Link
- func (*Link) Descriptor() ([]byte, []int)deprecated
- func (x *Link) GetValue() []byte
- func (l *Link) Marshal(lnk ipld.Link) error
- func (*Link) ProtoMessage()
- func (x *Link) ProtoReflect() protoreflect.Message
- func (x *Link) Reset()
- func (x *Link) String() string
- func (l *Link) Unmarshal() (ipld.Link, error)
- type Multihash
- type NotifyContent
- type NotifyContent_Request
- func (*NotifyContent_Request) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyContent_Request) GetMultihash() *Multihash
- func (*NotifyContent_Request) ProtoMessage()
- func (x *NotifyContent_Request) ProtoReflect() protoreflect.Message
- func (x *NotifyContent_Request) Reset()
- func (x *NotifyContent_Request) String() string
- type NotifyContent_Response
- func (*NotifyContent_Response) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyContent_Response) GetLink() *Link
- func (*NotifyContent_Response) ProtoMessage()
- func (x *NotifyContent_Response) ProtoReflect() protoreflect.Message
- func (x *NotifyContent_Response) Reset()
- func (x *NotifyContent_Response) String() string
- type Publish
- type Publish_Request
- type Publish_Response
- type PublisherClient
- type PublisherServer
- type Publisher_NotifyContentClient
- type Publisher_NotifyContentServer
- type UnimplementedPublisherServer
- type UnsafePublisherServer
Constants ¶
This section is empty.
Variables ¶
var File_depute_proto protoreflect.FileDescriptor
var Publisher_ServiceDesc = grpc.ServiceDesc{ ServiceName: "ipni.depute.v0.Publisher", HandlerType: (*PublisherServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Publish", Handler: _Publisher_Publish_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "NotifyContent", Handler: _Publisher_NotifyContent_Handler, ClientStreams: true, }, }, Metadata: "depute.proto", }
Publisher_ServiceDesc is the grpc.ServiceDesc for Publisher service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterPublisherServer ¶
func RegisterPublisherServer(s grpc.ServiceRegistrar, srv PublisherServer)
Types ¶
type Advertisement ¶
type Advertisement struct { ID *Link `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` Entries *Link `protobuf:"bytes,2,opt,name=entries,proto3,oneof" json:"entries,omitempty"` ContextId []byte `protobuf:"bytes,3,opt,name=context_id,json=contextId,proto3,oneof" json:"context_id,omitempty"` Metadata []byte `protobuf:"bytes,4,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"` Removed bool `protobuf:"varint,5,opt,name=removed,proto3" json:"removed,omitempty"` // contains filtered or unexported fields }
func (*Advertisement) Descriptor
deprecated
func (*Advertisement) Descriptor() ([]byte, []int)
Deprecated: Use Advertisement.ProtoReflect.Descriptor instead.
func (*Advertisement) GetContextId ¶
func (x *Advertisement) GetContextId() []byte
func (*Advertisement) GetEntries ¶
func (x *Advertisement) GetEntries() *Link
func (*Advertisement) GetID ¶
func (x *Advertisement) GetID() *Link
func (*Advertisement) GetMetadata ¶
func (x *Advertisement) GetMetadata() []byte
func (*Advertisement) GetRemoved ¶
func (x *Advertisement) GetRemoved() bool
func (*Advertisement) ProtoMessage ¶
func (*Advertisement) ProtoMessage()
func (*Advertisement) ProtoReflect ¶
func (x *Advertisement) ProtoReflect() protoreflect.Message
func (*Advertisement) Reset ¶
func (x *Advertisement) Reset()
func (*Advertisement) String ¶
func (x *Advertisement) String() string
type Link ¶
type Link struct { Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Link) Descriptor
deprecated
func (*Link) ProtoMessage ¶
func (*Link) ProtoMessage()
func (*Link) ProtoReflect ¶
func (x *Link) ProtoReflect() protoreflect.Message
type Multihash ¶
type Multihash struct { Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Multihash) Descriptor
deprecated
func (*Multihash) ProtoMessage ¶
func (*Multihash) ProtoMessage()
func (*Multihash) ProtoReflect ¶
func (x *Multihash) ProtoReflect() protoreflect.Message
type NotifyContent ¶
type NotifyContent struct {
// contains filtered or unexported fields
}
func (*NotifyContent) Descriptor
deprecated
func (*NotifyContent) Descriptor() ([]byte, []int)
Deprecated: Use NotifyContent.ProtoReflect.Descriptor instead.
func (*NotifyContent) ProtoMessage ¶
func (*NotifyContent) ProtoMessage()
func (*NotifyContent) ProtoReflect ¶
func (x *NotifyContent) ProtoReflect() protoreflect.Message
func (*NotifyContent) Reset ¶
func (x *NotifyContent) Reset()
func (*NotifyContent) String ¶
func (x *NotifyContent) String() string
type NotifyContent_Request ¶
type NotifyContent_Request struct { Multihash *Multihash `protobuf:"bytes,1,opt,name=multihash,proto3" json:"multihash,omitempty"` // contains filtered or unexported fields }
func (*NotifyContent_Request) Descriptor
deprecated
func (*NotifyContent_Request) Descriptor() ([]byte, []int)
Deprecated: Use NotifyContent_Request.ProtoReflect.Descriptor instead.
func (*NotifyContent_Request) GetMultihash ¶
func (x *NotifyContent_Request) GetMultihash() *Multihash
func (*NotifyContent_Request) ProtoMessage ¶
func (*NotifyContent_Request) ProtoMessage()
func (*NotifyContent_Request) ProtoReflect ¶
func (x *NotifyContent_Request) ProtoReflect() protoreflect.Message
func (*NotifyContent_Request) Reset ¶
func (x *NotifyContent_Request) Reset()
func (*NotifyContent_Request) String ¶
func (x *NotifyContent_Request) String() string
type NotifyContent_Response ¶
type NotifyContent_Response struct { Link *Link `protobuf:"bytes,1,opt,name=link,proto3" json:"link,omitempty"` // contains filtered or unexported fields }
func (*NotifyContent_Response) Descriptor
deprecated
func (*NotifyContent_Response) Descriptor() ([]byte, []int)
Deprecated: Use NotifyContent_Response.ProtoReflect.Descriptor instead.
func (*NotifyContent_Response) GetLink ¶
func (x *NotifyContent_Response) GetLink() *Link
func (*NotifyContent_Response) ProtoMessage ¶
func (*NotifyContent_Response) ProtoMessage()
func (*NotifyContent_Response) ProtoReflect ¶
func (x *NotifyContent_Response) ProtoReflect() protoreflect.Message
func (*NotifyContent_Response) Reset ¶
func (x *NotifyContent_Response) Reset()
func (*NotifyContent_Response) String ¶
func (x *NotifyContent_Response) String() string
type Publish ¶
type Publish struct {
// contains filtered or unexported fields
}
func (*Publish) Descriptor
deprecated
func (*Publish) ProtoMessage ¶
func (*Publish) ProtoMessage()
func (*Publish) ProtoReflect ¶
func (x *Publish) ProtoReflect() protoreflect.Message
type Publish_Request ¶
type Publish_Request struct { Advertisement *Advertisement `protobuf:"bytes,1,opt,name=advertisement,proto3" json:"advertisement,omitempty"` // contains filtered or unexported fields }
func (*Publish_Request) Descriptor
deprecated
func (*Publish_Request) Descriptor() ([]byte, []int)
Deprecated: Use Publish_Request.ProtoReflect.Descriptor instead.
func (*Publish_Request) GetAdvertisement ¶
func (x *Publish_Request) GetAdvertisement() *Advertisement
func (*Publish_Request) ProtoMessage ¶
func (*Publish_Request) ProtoMessage()
func (*Publish_Request) ProtoReflect ¶
func (x *Publish_Request) ProtoReflect() protoreflect.Message
func (*Publish_Request) Reset ¶
func (x *Publish_Request) Reset()
func (*Publish_Request) String ¶
func (x *Publish_Request) String() string
type Publish_Response ¶
type Publish_Response struct { Link *Link `protobuf:"bytes,1,opt,name=link,proto3" json:"link,omitempty"` // contains filtered or unexported fields }
func (*Publish_Response) Descriptor
deprecated
func (*Publish_Response) Descriptor() ([]byte, []int)
Deprecated: Use Publish_Response.ProtoReflect.Descriptor instead.
func (*Publish_Response) GetLink ¶
func (x *Publish_Response) GetLink() *Link
func (*Publish_Response) ProtoMessage ¶
func (*Publish_Response) ProtoMessage()
func (*Publish_Response) ProtoReflect ¶
func (x *Publish_Response) ProtoReflect() protoreflect.Message
func (*Publish_Response) Reset ¶
func (x *Publish_Response) Reset()
func (*Publish_Response) String ¶
func (x *Publish_Response) String() string
type PublisherClient ¶
type PublisherClient interface { NotifyContent(ctx context.Context, opts ...grpc.CallOption) (Publisher_NotifyContentClient, error) Publish(ctx context.Context, in *Publish_Request, opts ...grpc.CallOption) (*Publish_Response, error) }
PublisherClient is the client API for Publisher 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 NewPublisherClient ¶
func NewPublisherClient(cc grpc.ClientConnInterface) PublisherClient
type PublisherServer ¶
type PublisherServer interface { NotifyContent(Publisher_NotifyContentServer) error Publish(context.Context, *Publish_Request) (*Publish_Response, error) }
PublisherServer is the server API for Publisher service. All implementations should embed UnimplementedPublisherServer for forward compatibility
type Publisher_NotifyContentClient ¶
type Publisher_NotifyContentClient interface { Send(*NotifyContent_Request) error CloseAndRecv() (*NotifyContent_Response, error) grpc.ClientStream }
type Publisher_NotifyContentServer ¶
type Publisher_NotifyContentServer interface { SendAndClose(*NotifyContent_Response) error Recv() (*NotifyContent_Request, error) grpc.ServerStream }
type UnimplementedPublisherServer ¶
type UnimplementedPublisherServer struct { }
UnimplementedPublisherServer should be embedded to have forward compatible implementations.
func (UnimplementedPublisherServer) NotifyContent ¶
func (UnimplementedPublisherServer) NotifyContent(Publisher_NotifyContentServer) error
func (UnimplementedPublisherServer) Publish ¶
func (UnimplementedPublisherServer) Publish(context.Context, *Publish_Request) (*Publish_Response, error)
type UnsafePublisherServer ¶
type UnsafePublisherServer interface {
// contains filtered or unexported methods
}
UnsafePublisherServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PublisherServer will result in compilation errors.