Help us shape the future of Go! Take the 2026 Go Developer Survey

ghost

package
v0.28.0 Latest Latest
Warning

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

Go to latest
Published: Oct 13, 2022 License: AGPL-3.0 Imports: 8 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterGhostNodeAPIServer

func RegisterGhostNodeAPIServer(s *grpc.Server, srv GhostNodeAPIServer)

Types

type FlowMessage

type FlowMessage struct {
	SenderID             []byte   `protobuf:"bytes,1,opt,name=senderID,proto3" json:"senderID,omitempty"`
	Message              []byte   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FlowMessage) Descriptor

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

func (*FlowMessage) GetMessage

func (m *FlowMessage) GetMessage() []byte

func (*FlowMessage) GetSenderID

func (m *FlowMessage) GetSenderID() []byte

func (*FlowMessage) ProtoMessage

func (*FlowMessage) ProtoMessage()

func (*FlowMessage) Reset

func (m *FlowMessage) Reset()

func (*FlowMessage) String

func (m *FlowMessage) String() string

func (*FlowMessage) XXX_DiscardUnknown

func (m *FlowMessage) XXX_DiscardUnknown()

func (*FlowMessage) XXX_Marshal

func (m *FlowMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlowMessage) XXX_Merge

func (m *FlowMessage) XXX_Merge(src proto.Message)

func (*FlowMessage) XXX_Size

func (m *FlowMessage) XXX_Size() int

func (*FlowMessage) XXX_Unmarshal

func (m *FlowMessage) XXX_Unmarshal(b []byte) error

type GhostNodeAPIClient

type GhostNodeAPIClient interface {
	// SendEvent submits and event to the internal Flow Libp2p network
	SendEvent(ctx context.Context, in *SendEventRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Subscribe returns all network messages
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (GhostNodeAPI_SubscribeClient, error)
}

GhostNodeAPIClient is the client API for GhostNodeAPI service.

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

func NewGhostNodeAPIClient

func NewGhostNodeAPIClient(cc *grpc.ClientConn) GhostNodeAPIClient

type GhostNodeAPIServer

type GhostNodeAPIServer interface {
	// SendEvent submits and event to the internal Flow Libp2p network
	SendEvent(context.Context, *SendEventRequest) (*empty.Empty, error)
	// Subscribe returns all network messages
	Subscribe(*SubscribeRequest, GhostNodeAPI_SubscribeServer) error
}

GhostNodeAPIServer is the server API for GhostNodeAPI service.

type GhostNodeAPI_SubscribeClient

type GhostNodeAPI_SubscribeClient interface {
	Recv() (*FlowMessage, error)
	grpc.ClientStream
}

type GhostNodeAPI_SubscribeServer

type GhostNodeAPI_SubscribeServer interface {
	Send(*FlowMessage) error
	grpc.ServerStream
}

type SendEventRequest

type SendEventRequest struct {
	ChannelId            string   `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	Message              []byte   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	TargetID             [][]byte `protobuf:"bytes,3,rep,name=targetID,proto3" json:"targetID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SendEventRequest) Descriptor

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

func (*SendEventRequest) GetChannelId

func (m *SendEventRequest) GetChannelId() string

func (*SendEventRequest) GetMessage

func (m *SendEventRequest) GetMessage() []byte

func (*SendEventRequest) GetTargetID

func (m *SendEventRequest) GetTargetID() [][]byte

func (*SendEventRequest) ProtoMessage

func (*SendEventRequest) ProtoMessage()

func (*SendEventRequest) Reset

func (m *SendEventRequest) Reset()

func (*SendEventRequest) String

func (m *SendEventRequest) String() string

func (*SendEventRequest) XXX_DiscardUnknown

func (m *SendEventRequest) XXX_DiscardUnknown()

func (*SendEventRequest) XXX_Marshal

func (m *SendEventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SendEventRequest) XXX_Merge

func (m *SendEventRequest) XXX_Merge(src proto.Message)

func (*SendEventRequest) XXX_Size

func (m *SendEventRequest) XXX_Size() int

func (*SendEventRequest) XXX_Unmarshal

func (m *SendEventRequest) XXX_Unmarshal(b []byte) error

type SubscribeRequest

type SubscribeRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscribeRequest) Descriptor

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

func (*SubscribeRequest) ProtoMessage

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) String

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) XXX_DiscardUnknown

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal

func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeRequest) XXX_Merge

func (m *SubscribeRequest) XXX_Merge(src proto.Message)

func (*SubscribeRequest) XXX_Size

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal

func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error

type UnimplementedGhostNodeAPIServer

type UnimplementedGhostNodeAPIServer struct {
}

UnimplementedGhostNodeAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedGhostNodeAPIServer) SendEvent

func (*UnimplementedGhostNodeAPIServer) Subscribe

Jump to

Keyboard shortcuts

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