ghoeq

package
v0.0.0-...-4b4e322 Latest Latest
Warning

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

 Go to latest Published: May 2, 2024 License: GPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BackendServer_ListSources_FullMethodName        = "/ghoeq.BackendServer/ListSources"
	BackendServer_ListSession_FullMethodName        = "/ghoeq.BackendServer/ListSession"
	BackendServer_ListStreams_FullMethodName        = "/ghoeq.BackendServer/ListStreams"
	BackendServer_ListClients_FullMethodName        = "/ghoeq.BackendServer/ListClients"
	BackendServer_ModifySession_FullMethodName      = "/ghoeq.BackendServer/ModifySession"
	BackendServer_AttachSessionRaw_FullMethodName   = "/ghoeq.BackendServer/AttachSessionRaw"
	BackendServer_AttachClientStream_FullMethodName = "/ghoeq.BackendServer/AttachClientStream"
	BackendServer_AttachClient_FullMethodName       = "/ghoeq.BackendServer/AttachClient"
	BackendServer_AttachStreamRaw_FullMethodName    = "/ghoeq.BackendServer/AttachStreamRaw"
	BackendServer_AttachStreamStruct_FullMethodName = "/ghoeq.BackendServer/AttachStreamStruct"
)

Variables

View Source 
var (
	State_name = map[int32]string{
		0: "STATE_UNKNOWN",
		1: "STATE_START",
		2: "STATE_STOP",
	}
	State_value = map[string]int32{
		"STATE_UNKNOWN": 0,
		"STATE_START":   1,
		"STATE_STOP":    2,
	}
)

Enum value maps for State.

View Source 
var (
	PeerType_name = map[int32]string{
		0: "PEER_UNKNOWN",
		1: "PEER_LOGIN",
		2: "PEER_WORLD",
		3: "PEER_ZONE",
		4: "PEER_CHAT",
	}
	PeerType_value = map[string]int32{
		"PEER_UNKNOWN": 0,
		"PEER_LOGIN":   1,
		"PEER_WORLD":   2,
		"PEER_ZONE":    3,
		"PEER_CHAT":    4,
	}
)

Enum value maps for PeerType.

View Source 
var (
	Direction_name = map[int32]string{
		0: "DIR_UNKNOWN",
		1: "DIR_CLIENT_TO_SERVER",
		2: "DIR_SERVER_TO_CLIENT",
	}
	Direction_value = map[string]int32{
		"DIR_UNKNOWN":          0,
		"DIR_CLIENT_TO_SERVER": 1,
		"DIR_SERVER_TO_CLIENT": 2,
	}
)

Enum value maps for Direction.

View Source 
var BackendServer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ghoeq.BackendServer",
	HandlerType: (*BackendServerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListSources",
			Handler:    _BackendServer_ListSources_Handler,
		},
		{
			MethodName: "ListSession",
			Handler:    _BackendServer_ListSession_Handler,
		},
		{
			MethodName: "ListStreams",
			Handler:    _BackendServer_ListStreams_Handler,
		},
		{
			MethodName: "ListClients",
			Handler:    _BackendServer_ListClients_Handler,
		},
		{
			MethodName: "ModifySession",
			Handler:    _BackendServer_ModifySession_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "AttachSessionRaw",
			Handler:       _BackendServer_AttachSessionRaw_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "AttachClientStream",
			Handler:       _BackendServer_AttachClientStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "AttachClient",
			Handler:       _BackendServer_AttachClient_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "AttachStreamRaw",
			Handler:       _BackendServer_AttachStreamRaw_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "AttachStreamStruct",
			Handler:       _BackendServer_AttachStreamStruct_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/ghoeq/ghoeq.proto",
}

BackendServer_ServiceDesc is the grpc.ServiceDesc for BackendServer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_proto_ghoeq_ghoeq_proto protoreflect.FileDescriptor

Functions

func RegisterBackendServerServer 

func RegisterBackendServerServer(s grpc.ServiceRegistrar, srv BackendServerServer)

Types

type APPacket 

type APPacket struct {
	Seq      uint64                 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
	OpCode   uint32                 `protobuf:"varint,2,opt,name=op_code,json=opCode,proto3" json:"op_code,omitempty"`
	Data     []byte                 `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	StreamId string                 `protobuf:"bytes,5,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Origin   *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

func (*APPacket) Descriptor deprecated 

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

Deprecated: Use APPacket.ProtoReflect.Descriptor instead.

func (*APPacket) GetData 

func (x *APPacket) GetData() []byte

func (*APPacket) GetOpCode 

func (x *APPacket) GetOpCode() uint32

func (*APPacket) GetOrigin 

func (x *APPacket) GetOrigin() *timestamppb.Timestamp

func (*APPacket) GetSeq 

func (x *APPacket) GetSeq() uint64

func (*APPacket) GetStreamId 

func (x *APPacket) GetStreamId() string

func (*APPacket) ProtoMessage 

func (*APPacket) ProtoMessage()

func (*APPacket) ProtoReflect 

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

func (*APPacket) Reset 

func (x *APPacket) Reset()

func (*APPacket) String 

func (x *APPacket) String() string

type AttachClientRequest 

type AttachClientRequest struct {
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AttachClientRequest) Descriptor deprecated 

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

Deprecated: Use AttachClientRequest.ProtoReflect.Descriptor instead.

func (*AttachClientRequest) GetClientId 

func (x *AttachClientRequest) GetClientId() string

func (*AttachClientRequest) ProtoMessage 

func (*AttachClientRequest) ProtoMessage()

func (*AttachClientRequest) ProtoReflect 

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

func (*AttachClientRequest) Reset 

func (x *AttachClientRequest) Reset()

func (*AttachClientRequest) String 

func (x *AttachClientRequest) String() string

type AttachClientStreamRequest 

type AttachClientStreamRequest struct {
	ClientId   string                 `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	LastUpdate *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_update,json=lastUpdate,proto3" json:"last_update,omitempty"` // Used to mark current knowledge time.
	// contains filtered or unexported fields
}

func (*AttachClientStreamRequest) Descriptor deprecated 

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

Deprecated: Use AttachClientStreamRequest.ProtoReflect.Descriptor instead.

func (*AttachClientStreamRequest) GetClientId 

func (x *AttachClientStreamRequest) GetClientId() string

func (*AttachClientStreamRequest) GetLastUpdate 

func (x *AttachClientStreamRequest) GetLastUpdate() *timestamppb.Timestamp

func (*AttachClientStreamRequest) ProtoMessage 

func (*AttachClientStreamRequest) ProtoMessage()

func (*AttachClientStreamRequest) ProtoReflect 

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

func (*AttachClientStreamRequest) Reset 

func (x *AttachClientStreamRequest) Reset()

func (*AttachClientStreamRequest) String 

func (x *AttachClientStreamRequest) String() string

type AttachSessionRequest 

type AttachSessionRequest struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AttachSessionRequest) Descriptor deprecated 

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

Deprecated: Use AttachSessionRequest.ProtoReflect.Descriptor instead.

func (*AttachSessionRequest) GetSessionId 

func (x *AttachSessionRequest) GetSessionId() string

func (*AttachSessionRequest) ProtoMessage 

func (*AttachSessionRequest) ProtoMessage()

func (*AttachSessionRequest) ProtoReflect 

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

func (*AttachSessionRequest) Reset 

func (x *AttachSessionRequest) Reset()

func (*AttachSessionRequest) String 

func (x *AttachSessionRequest) String() string

type AttachStreamRequest 

type AttachStreamRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`    // Start pulling a specific stream, or 0 for first avaliable if one or none.
	Seq       uint64 `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"` // Used for resume from previous sequence number. Not implmented yet.
	SessionId string `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AttachStreamRequest) Descriptor deprecated 

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

Deprecated: Use AttachStreamRequest.ProtoReflect.Descriptor instead.

func (*AttachStreamRequest) GetId 

func (x *AttachStreamRequest) GetId() string

func (*AttachStreamRequest) GetSeq 

func (x *AttachStreamRequest) GetSeq() uint64

func (*AttachStreamRequest) GetSessionId 

func (x *AttachStreamRequest) GetSessionId() string

func (*AttachStreamRequest) ProtoMessage 

func (*AttachStreamRequest) ProtoMessage()

func (*AttachStreamRequest) ProtoReflect 

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

func (*AttachStreamRequest) Reset 

func (x *AttachStreamRequest) Reset()

func (*AttachStreamRequest) String 

func (x *AttachStreamRequest) String() string

type BackendServerClient 

type BackendServerClient interface {
	ListSources(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListSourcesResponse, error)
	ListSession(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListSessionResponse, error)
	ListStreams(ctx context.Context, in *ListStreamRequest, opts ...grpc.CallOption) (*ListStreamsResponse, error)
	ListClients(ctx context.Context, in *ListClientRequest, opts ...grpc.CallOption) (*ListClientsResponse, error)
	ModifySession(ctx context.Context, in *ModifySessionRequest, opts ...grpc.CallOption) (*ModifySessionResponse, error)
	AttachSessionRaw(ctx context.Context, in *AttachSessionRequest, opts ...grpc.CallOption) (BackendServer_AttachSessionRawClient, error)
	AttachClientStream(ctx context.Context, in *AttachClientStreamRequest, opts ...grpc.CallOption) (BackendServer_AttachClientStreamClient, error)
	AttachClient(ctx context.Context, in *AttachClientRequest, opts ...grpc.CallOption) (BackendServer_AttachClientClient, error)
	AttachStreamRaw(ctx context.Context, in *AttachStreamRequest, opts ...grpc.CallOption) (BackendServer_AttachStreamRawClient, error)
	AttachStreamStruct(ctx context.Context, in *AttachStreamRequest, opts ...grpc.CallOption) (BackendServer_AttachStreamStructClient, error)
}

BackendServerClient is the client API for BackendServer 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 NewBackendServerClient 

func NewBackendServerClient(cc grpc.ClientConnInterface) BackendServerClient

type BackendServerServer 

type BackendServerServer interface {
	ListSources(context.Context, *ListRequest) (*ListSourcesResponse, error)
	ListSession(context.Context, *ListRequest) (*ListSessionResponse, error)
	ListStreams(context.Context, *ListStreamRequest) (*ListStreamsResponse, error)
	ListClients(context.Context, *ListClientRequest) (*ListClientsResponse, error)
	ModifySession(context.Context, *ModifySessionRequest) (*ModifySessionResponse, error)
	AttachSessionRaw(*AttachSessionRequest, BackendServer_AttachSessionRawServer) error
	AttachClientStream(*AttachClientStreamRequest, BackendServer_AttachClientStreamServer) error
	AttachClient(*AttachClientRequest, BackendServer_AttachClientServer) error
	AttachStreamRaw(*AttachStreamRequest, BackendServer_AttachStreamRawServer) error
	AttachStreamStruct(*AttachStreamRequest, BackendServer_AttachStreamStructServer) error
	// contains filtered or unexported methods
}

BackendServerServer is the server API for BackendServer service. All implementations must embed UnimplementedBackendServerServer for forward compatibility

type BackendServer_AttachClientClient 

type BackendServer_AttachClientClient interface {
	Recv() (*ClientUpdate, error)
	grpc.ClientStream
}

type BackendServer_AttachClientServer 

type BackendServer_AttachClientServer interface {
	Send(*ClientUpdate) error
	grpc.ServerStream
}

type BackendServer_AttachClientStreamClient 

type BackendServer_AttachClientStreamClient interface {
	Recv() (*ClientPacket, error)
	grpc.ClientStream
}

type BackendServer_AttachClientStreamServer 

type BackendServer_AttachClientStreamServer interface {
	Send(*ClientPacket) error
	grpc.ServerStream
}

type BackendServer_AttachSessionRawClient 

type BackendServer_AttachSessionRawClient interface {
	Recv() (*APPacket, error)
	grpc.ClientStream
}

type BackendServer_AttachSessionRawServer 

type BackendServer_AttachSessionRawServer interface {
	Send(*APPacket) error
	grpc.ServerStream
}

type BackendServer_AttachStreamRawClient 

type BackendServer_AttachStreamRawClient interface {
	Recv() (*APPacket, error)
	grpc.ClientStream
}

type BackendServer_AttachStreamRawServer 

type BackendServer_AttachStreamRawServer interface {
	Send(*APPacket) error
	grpc.ServerStream
}

type BackendServer_AttachStreamStructClient 

type BackendServer_AttachStreamStructClient interface {
	Recv() (*ClientPacket, error)
	grpc.ClientStream
}

type BackendServer_AttachStreamStructServer 

type BackendServer_AttachStreamStructServer interface {
	Send(*ClientPacket) error
	grpc.ServerStream
}

type Client 

type Client struct {
	Id            string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address       string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	ServerName    string `protobuf:"bytes,3,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"`
	CharacterName string `protobuf:"bytes,4,opt,name=character_name,json=characterName,proto3" json:"character_name,omitempty"`
	// contains filtered or unexported fields
}

func (*Client) Descriptor deprecated 

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

Deprecated: Use Client.ProtoReflect.Descriptor instead.

func (*Client) GetAddress 

func (x *Client) GetAddress() string

func (*Client) GetCharacterName 

func (x *Client) GetCharacterName() string

func (*Client) GetId 

func (x *Client) GetId() string

func (*Client) GetServerName 

func (x *Client) GetServerName() string

func (*Client) ProtoMessage 

func (*Client) ProtoMessage()

func (*Client) ProtoReflect 

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

func (*Client) Reset 

func (x *Client) Reset()

func (*Client) String 

func (x *Client) String() string

type ClientPacket 

type ClientPacket struct {
	Seq      uint64                 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
	OpCode   uint32                 `protobuf:"varint,2,opt,name=op_code,json=opCode,proto3" json:"op_code,omitempty"`
	Struct   *eqstruct.DataStruct   `protobuf:"bytes,3,opt,name=struct,proto3" json:"struct,omitempty"`
	StreamId string                 `protobuf:"bytes,4,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Origin   *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=origin,proto3" json:"origin,omitempty"`
	Data     []byte                 `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientPacket) Descriptor deprecated 

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

Deprecated: Use ClientPacket.ProtoReflect.Descriptor instead.

func (*ClientPacket) GetData 

func (x *ClientPacket) GetData() []byte

func (*ClientPacket) GetOpCode 

func (x *ClientPacket) GetOpCode() uint32

func (*ClientPacket) GetOrigin 

func (x *ClientPacket) GetOrigin() *timestamppb.Timestamp

func (*ClientPacket) GetSeq 

func (x *ClientPacket) GetSeq() uint64

func (*ClientPacket) GetStreamId 

func (x *ClientPacket) GetStreamId() string

func (*ClientPacket) GetStruct 

func (x *ClientPacket) GetStruct() *eqstruct.DataStruct

func (*ClientPacket) ProtoMessage 

func (*ClientPacket) ProtoMessage()

func (*ClientPacket) ProtoReflect 

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

func (*ClientPacket) Reset 

func (x *ClientPacket) Reset()

func (*ClientPacket) String 

func (x *ClientPacket) String() string

type ClientUpdate 

type ClientUpdate struct {
	Streams []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
	Client  *Client   `protobuf:"bytes,2,opt,name=client,proto3" json:"client,omitempty"` // Offered on first avail
	// contains filtered or unexported fields
}

func (*ClientUpdate) Descriptor deprecated 

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

Deprecated: Use ClientUpdate.ProtoReflect.Descriptor instead.

func (*ClientUpdate) GetClient 

func (x *ClientUpdate) GetClient() *Client

func (*ClientUpdate) GetStreams 

func (x *ClientUpdate) GetStreams() []*Stream

func (*ClientUpdate) ProtoMessage 

func (*ClientUpdate) ProtoMessage()

func (*ClientUpdate) ProtoReflect 

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

func (*ClientUpdate) Reset 

func (x *ClientUpdate) Reset()

func (*ClientUpdate) String 

func (x *ClientUpdate) String() string

type Direction 

type Direction int32
const (
	Direction_DIR_UNKNOWN          Direction = 0
	Direction_DIR_CLIENT_TO_SERVER Direction = 1
	Direction_DIR_SERVER_TO_CLIENT Direction = 2
)

func (Direction) Descriptor 

func (Direction) Descriptor() protoreflect.EnumDescriptor

func (Direction) Enum 

func (x Direction) Enum() *Direction

func (Direction) EnumDescriptor deprecated 

func (Direction) EnumDescriptor() ([]byte, []int)

Deprecated: Use Direction.Descriptor instead.

func (Direction) Number 

func (x Direction) Number() protoreflect.EnumNumber

func (Direction) String 

func (x Direction) String() string

func (Direction) Type 

func (Direction) Type() protoreflect.EnumType

type GameStream 

type GameStream struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// google.protobuf.DateTime first_seen = 2;
	Client   *Client   `protobuf:"bytes,3,opt,name=client,proto3" json:"client,omitempty"`
	Sessions []*Stream `protobuf:"bytes,4,rep,name=sessions,proto3" json:"sessions,omitempty"`
	// contains filtered or unexported fields
}

func (*GameStream) Descriptor deprecated 

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

Deprecated: Use GameStream.ProtoReflect.Descriptor instead.

func (*GameStream) GetClient 

func (x *GameStream) GetClient() *Client

func (*GameStream) GetId 

func (x *GameStream) GetId() uint32

func (*GameStream) GetSessions 

func (x *GameStream) GetSessions() []*Stream

func (*GameStream) ProtoMessage 

func (*GameStream) ProtoMessage()

func (*GameStream) ProtoReflect 

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

func (*GameStream) Reset 

func (x *GameStream) Reset()

func (*GameStream) String 

func (x *GameStream) String() string

type HistoryComplete 

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

func (*HistoryComplete) Descriptor deprecated 

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

Deprecated: Use HistoryComplete.ProtoReflect.Descriptor instead.

func (*HistoryComplete) ProtoMessage 

func (*HistoryComplete) ProtoMessage()

func (*HistoryComplete) ProtoReflect 

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

func (*HistoryComplete) Reset 

func (x *HistoryComplete) Reset()

func (*HistoryComplete) String 

func (x *HistoryComplete) String() string

type ListClientRequest 

type ListClientRequest struct {
	Id            string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ServerName    string `protobuf:"bytes,2,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"`
	CharacterName string `protobuf:"bytes,3,opt,name=character_name,json=characterName,proto3" json:"character_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClientRequest) Descriptor deprecated 

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

Deprecated: Use ListClientRequest.ProtoReflect.Descriptor instead.

func (*ListClientRequest) GetCharacterName 

func (x *ListClientRequest) GetCharacterName() string

func (*ListClientRequest) GetId 

func (x *ListClientRequest) GetId() string

func (*ListClientRequest) GetServerName 

func (x *ListClientRequest) GetServerName() string

func (*ListClientRequest) ProtoMessage 

func (*ListClientRequest) ProtoMessage()

func (*ListClientRequest) ProtoReflect 

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

func (*ListClientRequest) Reset 

func (x *ListClientRequest) Reset()

func (*ListClientRequest) String 

func (x *ListClientRequest) String() string

type ListClientsResponse 

type ListClientsResponse struct {
	Clients []*GameStream `protobuf:"bytes,1,rep,name=clients,proto3" json:"clients,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClientsResponse) Descriptor deprecated 

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

Deprecated: Use ListClientsResponse.ProtoReflect.Descriptor instead.

func (*ListClientsResponse) GetClients 

func (x *ListClientsResponse) GetClients() []*GameStream

func (*ListClientsResponse) ProtoMessage 

func (*ListClientsResponse) ProtoMessage()

func (*ListClientsResponse) ProtoReflect 

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

func (*ListClientsResponse) Reset 

func (x *ListClientsResponse) Reset()

func (*ListClientsResponse) String 

func (x *ListClientsResponse) String() string

type ListRequest 

type ListRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetId 

func (x *ListRequest) GetId() string

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListSessionResponse 

type ListSessionResponse struct {
	Sessions []*Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSessionResponse) Descriptor deprecated 

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

Deprecated: Use ListSessionResponse.ProtoReflect.Descriptor instead.

func (*ListSessionResponse) GetSessions 

func (x *ListSessionResponse) GetSessions() []*Session

func (*ListSessionResponse) ProtoMessage 

func (*ListSessionResponse) ProtoMessage()

func (*ListSessionResponse) ProtoReflect 

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

func (*ListSessionResponse) Reset 

func (x *ListSessionResponse) Reset()

func (*ListSessionResponse) String 

func (x *ListSessionResponse) String() string

type ListSourcesResponse 

type ListSourcesResponse struct {
	Sources []*Source `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSourcesResponse) Descriptor deprecated 

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

Deprecated: Use ListSourcesResponse.ProtoReflect.Descriptor instead.

func (*ListSourcesResponse) GetSources 

func (x *ListSourcesResponse) GetSources() []*Source

func (*ListSourcesResponse) ProtoMessage 

func (*ListSourcesResponse) ProtoMessage()

func (*ListSourcesResponse) ProtoReflect 

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

func (*ListSourcesResponse) Reset 

func (x *ListSourcesResponse) Reset()

func (*ListSourcesResponse) String 

func (x *ListSourcesResponse) String() string

type ListStreamRequest 

type ListStreamRequest struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	StreamId  string `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStreamRequest) Descriptor deprecated 

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

Deprecated: Use ListStreamRequest.ProtoReflect.Descriptor instead.

func (*ListStreamRequest) GetSessionId 

func (x *ListStreamRequest) GetSessionId() string

func (*ListStreamRequest) GetStreamId 

func (x *ListStreamRequest) GetStreamId() string

func (*ListStreamRequest) ProtoMessage 

func (*ListStreamRequest) ProtoMessage()

func (*ListStreamRequest) ProtoReflect 

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

func (*ListStreamRequest) Reset 

func (x *ListStreamRequest) Reset()

func (*ListStreamRequest) String 

func (x *ListStreamRequest) String() string

type ListStreamsResponse 

type ListStreamsResponse struct {
	Streams []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStreamsResponse) Descriptor deprecated 

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

Deprecated: Use ListStreamsResponse.ProtoReflect.Descriptor instead.

func (*ListStreamsResponse) GetStreams 

func (x *ListStreamsResponse) GetStreams() []*Stream

func (*ListStreamsResponse) ProtoMessage 

func (*ListStreamsResponse) ProtoMessage()

func (*ListStreamsResponse) ProtoReflect 

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

func (*ListStreamsResponse) Reset 

func (x *ListStreamsResponse) Reset()

func (*ListStreamsResponse) String 

func (x *ListStreamsResponse) String() string

type ModifyRequest 

type ModifyRequest struct {
	Id     uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	State  State  `protobuf:"varint,2,opt,name=state,proto3,enum=ghoeq.State" json:"state,omitempty"`
	Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyRequest) Descriptor deprecated 

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

Deprecated: Use ModifyRequest.ProtoReflect.Descriptor instead.

func (*ModifyRequest) GetId 

func (x *ModifyRequest) GetId() uint32

func (*ModifyRequest) GetSource 

func (x *ModifyRequest) GetSource() string

func (*ModifyRequest) GetState 

func (x *ModifyRequest) GetState() State

func (*ModifyRequest) ProtoMessage 

func (*ModifyRequest) ProtoMessage()

func (*ModifyRequest) ProtoReflect 

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

func (*ModifyRequest) Reset 

func (x *ModifyRequest) Reset()

func (*ModifyRequest) String 

func (x *ModifyRequest) String() string

type ModifySessionRequest 

type ModifySessionRequest struct {
	Mods  []*ModifyRequest `protobuf:"bytes,1,rep,name=mods,proto3" json:"mods,omitempty"`
	Nonce string           `protobuf:"bytes,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifySessionRequest) Descriptor deprecated 

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

Deprecated: Use ModifySessionRequest.ProtoReflect.Descriptor instead.

func (*ModifySessionRequest) GetMods 

func (x *ModifySessionRequest) GetMods() []*ModifyRequest

func (*ModifySessionRequest) GetNonce 

func (x *ModifySessionRequest) GetNonce() string

func (*ModifySessionRequest) ProtoMessage 

func (*ModifySessionRequest) ProtoMessage()

func (*ModifySessionRequest) ProtoReflect 

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

func (*ModifySessionRequest) Reset 

func (x *ModifySessionRequest) Reset()

func (*ModifySessionRequest) String 

func (x *ModifySessionRequest) String() string

type ModifySessionResponse 

type ModifySessionResponse struct {
	Responses []*SessionResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifySessionResponse) Descriptor deprecated 

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

Deprecated: Use ModifySessionResponse.ProtoReflect.Descriptor instead.

func (*ModifySessionResponse) GetResponses 

func (x *ModifySessionResponse) GetResponses() []*SessionResponse

func (*ModifySessionResponse) ProtoMessage 

func (*ModifySessionResponse) ProtoMessage()

func (*ModifySessionResponse) ProtoReflect 

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

func (*ModifySessionResponse) Reset 

func (x *ModifySessionResponse) Reset()

func (*ModifySessionResponse) String 

func (x *ModifySessionResponse) String() string

type PeerType 

type PeerType int32
const (
	PeerType_PEER_UNKNOWN PeerType = 0
	PeerType_PEER_LOGIN   PeerType = 1
	PeerType_PEER_WORLD   PeerType = 2
	PeerType_PEER_ZONE    PeerType = 3
	PeerType_PEER_CHAT    PeerType = 4
)

func (PeerType) Descriptor 

func (PeerType) Descriptor() protoreflect.EnumDescriptor

func (PeerType) Enum 

func (x PeerType) Enum() *PeerType

func (PeerType) EnumDescriptor deprecated 

func (PeerType) EnumDescriptor() ([]byte, []int)

Deprecated: Use PeerType.Descriptor instead.

func (PeerType) Number 

func (x PeerType) Number() protoreflect.EnumNumber

func (PeerType) String 

func (x PeerType) String() string

func (PeerType) Type 

func (PeerType) Type() protoreflect.EnumType

type Session 

type Session struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` //Interface / PacketCapture etc
	// contains filtered or unexported fields
}

func (*Session) Descriptor deprecated 

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

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetId 

func (x *Session) GetId() string

func (*Session) GetSource 

func (x *Session) GetSource() string

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) ProtoReflect 

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

func (*Session) Reset 

func (x *Session) Reset()

func (*Session) String 

func (x *Session) String() string

type SessionResponse 

type SessionResponse struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State State  `protobuf:"varint,2,opt,name=state,proto3,enum=ghoeq.State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionResponse) Descriptor deprecated 

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

Deprecated: Use SessionResponse.ProtoReflect.Descriptor instead.

func (*SessionResponse) GetId 

func (x *SessionResponse) GetId() string

func (*SessionResponse) GetState 

func (x *SessionResponse) GetState() State

func (*SessionResponse) ProtoMessage 

func (*SessionResponse) ProtoMessage()

func (*SessionResponse) ProtoReflect 

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

func (*SessionResponse) Reset 

func (x *SessionResponse) Reset()

func (*SessionResponse) String 

func (x *SessionResponse) String() string

type Source 

type Source struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*Source) Descriptor deprecated 

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

Deprecated: Use Source.ProtoReflect.Descriptor instead.

func (*Source) GetDescription 

func (x *Source) GetDescription() string

func (*Source) GetId 

func (x *Source) GetId() string

func (*Source) ProtoMessage 

func (*Source) ProtoMessage()

func (*Source) ProtoReflect 

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

func (*Source) Reset 

func (x *Source) Reset()

func (*Source) String 

func (x *Source) String() string

type State 

type State int32
const (
	State_STATE_UNKNOWN State = 0
	State_STATE_START   State = 1
	State_STATE_STOP    State = 2
)

func (State) Descriptor 

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum 

func (x State) Enum() *State

func (State) EnumDescriptor deprecated 

func (State) EnumDescriptor() ([]byte, []int)

Deprecated: Use State.Descriptor instead.

func (State) Number 

func (x State) Number() protoreflect.EnumNumber

func (State) String 

func (x State) String() string

func (State) Type 

func (State) Type() protoreflect.EnumType

type Stream 

type Stream struct {
	Id          string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Port        string    `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"`
	PeerAddress string    `protobuf:"bytes,3,opt,name=peer_address,json=peerAddress,proto3" json:"peer_address,omitempty"`
	PeerPort    string    `protobuf:"bytes,4,opt,name=peer_port,json=peerPort,proto3" json:"peer_port,omitempty"`
	Type        PeerType  `protobuf:"varint,5,opt,name=type,proto3,enum=ghoeq.PeerType" json:"type,omitempty"`
	Address     string    `protobuf:"bytes,6,opt,name=address,proto3" json:"address,omitempty"`
	Direction   Direction `protobuf:"varint,7,opt,name=direction,proto3,enum=ghoeq.Direction" json:"direction,omitempty"`
	Session     *Session  `protobuf:"bytes,8,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*Stream) Descriptor deprecated 

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

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetAddress 

func (x *Stream) GetAddress() string

func (*Stream) GetDirection 

func (x *Stream) GetDirection() Direction

func (*Stream) GetId 

func (x *Stream) GetId() string

func (*Stream) GetPeerAddress 

func (x *Stream) GetPeerAddress() string

func (*Stream) GetPeerPort 

func (x *Stream) GetPeerPort() string

func (*Stream) GetPort 

func (x *Stream) GetPort() string

func (*Stream) GetSession 

func (x *Stream) GetSession() *Session

func (*Stream) GetType 

func (x *Stream) GetType() PeerType

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect 

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

func (*Stream) Reset 

func (x *Stream) Reset()

func (*Stream) String 

func (x *Stream) String() string

type UnimplementedBackendServerServer 

type UnimplementedBackendServerServer struct {
}

UnimplementedBackendServerServer must be embedded to have forward compatible implementations.

func (UnimplementedBackendServerServer) AttachClient 

func (UnimplementedBackendServerServer) AttachClient(*AttachClientRequest, BackendServer_AttachClientServer) error

func (UnimplementedBackendServerServer) AttachClientStream 

func (UnimplementedBackendServerServer) AttachClientStream(*AttachClientStreamRequest, BackendServer_AttachClientStreamServer) error

func (UnimplementedBackendServerServer) AttachSessionRaw 

func (UnimplementedBackendServerServer) AttachSessionRaw(*AttachSessionRequest, BackendServer_AttachSessionRawServer) error

func (UnimplementedBackendServerServer) AttachStreamRaw 

func (UnimplementedBackendServerServer) AttachStreamRaw(*AttachStreamRequest, BackendServer_AttachStreamRawServer) error

func (UnimplementedBackendServerServer) AttachStreamStruct 

func (UnimplementedBackendServerServer) AttachStreamStruct(*AttachStreamRequest, BackendServer_AttachStreamStructServer) error

func (UnimplementedBackendServerServer) ListClients 

func (UnimplementedBackendServerServer) ListClients(context.Context, *ListClientRequest) (*ListClientsResponse, error)

func (UnimplementedBackendServerServer) ListSession 

func (UnimplementedBackendServerServer) ListSession(context.Context, *ListRequest) (*ListSessionResponse, error)

func (UnimplementedBackendServerServer) ListSources 

func (UnimplementedBackendServerServer) ListSources(context.Context, *ListRequest) (*ListSourcesResponse, error)

func (UnimplementedBackendServerServer) ListStreams 

func (UnimplementedBackendServerServer) ListStreams(context.Context, *ListStreamRequest) (*ListStreamsResponse, error)

func (UnimplementedBackendServerServer) ModifySession 

func (UnimplementedBackendServerServer) ModifySession(context.Context, *ModifySessionRequest) (*ModifySessionResponse, error)

type UnsafeBackendServerServer 

type UnsafeBackendServerServer interface {
	// contains filtered or unexported methods
}

UnsafeBackendServerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BackendServerServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.