depute

package
v0.0.0-...-2bebc66 Latest Latest
Warning

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

Go to latest
Published: Mar 15, 2024 License: Apache-2.0, MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_depute_proto protoreflect.FileDescriptor
View Source
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 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 struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Link) Descriptor deprecated

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

Deprecated: Use Link.ProtoReflect.Descriptor instead.

func (*Link) GetValue

func (x *Link) GetValue() []byte

func (*Link) Marshal

func (l *Link) Marshal(lnk ipld.Link) error

func (*Link) ProtoMessage

func (*Link) ProtoMessage()

func (*Link) ProtoReflect

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

func (*Link) Reset

func (x *Link) Reset()

func (*Link) String

func (x *Link) String() string

func (*Link) Unmarshal

func (l *Link) Unmarshal() (ipld.Link, error)

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) Descriptor() ([]byte, []int)

Deprecated: Use Multihash.ProtoReflect.Descriptor instead.

func (*Multihash) GetValue

func (x *Multihash) GetValue() []byte

func (*Multihash) ProtoMessage

func (*Multihash) ProtoMessage()

func (*Multihash) ProtoReflect

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

func (*Multihash) Reset

func (x *Multihash) Reset()

func (*Multihash) String

func (x *Multihash) String() string

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 (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) Descriptor() ([]byte, []int)

Deprecated: Use Publish.ProtoReflect.Descriptor instead.

func (*Publish) ProtoMessage

func (*Publish) ProtoMessage()

func (*Publish) ProtoReflect

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

func (*Publish) Reset

func (x *Publish) Reset()

func (*Publish) String

func (x *Publish) String() string

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 (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) Publish

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL