v1

package
v0.0.0-...-505e429 Latest Latest
Warning

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

 Go to latest Published: Oct 17, 2022 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const OperationKakaDebug = "/api.kaka.v1.Kaka/Debug"

Variables

View Source 
var File_kaka_v1_kaka_proto protoreflect.FileDescriptor
View Source 
var Kaka_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.kaka.v1.Kaka",
	HandlerType: (*KakaServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Debug",
			Handler:    _Kaka_Debug_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "kaka/v1/kaka.proto",
}

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

Functions

func RegisterKakaHTTPServer 

func RegisterKakaHTTPServer(s *http.Server, srv KakaHTTPServer)

func RegisterKakaServer 

func RegisterKakaServer(s grpc.ServiceRegistrar, srv KakaServer)

Types

type Channel 

type Channel struct {
	Id      string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Source  *Session   `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Clients []*Session `protobuf:"bytes,3,rep,name=clients,proto3" json:"clients,omitempty"`
	// contains filtered or unexported fields
}

func (*Channel) Descriptor deprecated 

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

Deprecated: Use Channel.ProtoReflect.Descriptor instead.

func (*Channel) GetClients 

func (x *Channel) GetClients() []*Session

func (*Channel) GetId 

func (x *Channel) GetId() string

func (*Channel) GetSource 

func (x *Channel) GetSource() *Session

func (*Channel) ProtoMessage 

func (*Channel) ProtoMessage()

func (*Channel) ProtoReflect 

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

func (*Channel) Reset 

func (x *Channel) Reset()

func (*Channel) String 

func (x *Channel) String() string

type DebugReply 

type DebugReply struct {
	Channels []*Channel `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,omitempty"`
	// contains filtered or unexported fields
}

func (*DebugReply) Descriptor deprecated 

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

Deprecated: Use DebugReply.ProtoReflect.Descriptor instead.

func (*DebugReply) GetChannels 

func (x *DebugReply) GetChannels() []*Channel

func (*DebugReply) ProtoMessage 

func (*DebugReply) ProtoMessage()

func (*DebugReply) ProtoReflect 

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

func (*DebugReply) Reset 

func (x *DebugReply) Reset()

func (*DebugReply) String 

func (x *DebugReply) String() string

type DebugRequest 

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

func (*DebugRequest) Descriptor deprecated 

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

Deprecated: Use DebugRequest.ProtoReflect.Descriptor instead.

func (*DebugRequest) ProtoMessage 

func (*DebugRequest) ProtoMessage()

func (*DebugRequest) ProtoReflect 

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

func (*DebugRequest) Reset 

func (x *DebugRequest) Reset()

func (*DebugRequest) String 

func (x *DebugRequest) String() string

type KakaClient 

type KakaClient interface {
	Debug(ctx context.Context, in *DebugRequest, opts ...grpc.CallOption) (*DebugReply, error)
}

KakaClient is the client API for Kaka 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 NewKakaClient 

func NewKakaClient(cc grpc.ClientConnInterface) KakaClient

type KakaHTTPClient 

type KakaHTTPClient interface {
	Debug(ctx context.Context, req *DebugRequest, opts ...http.CallOption) (rsp *DebugReply, err error)
}

func NewKakaHTTPClient 

func NewKakaHTTPClient(client *http.Client) KakaHTTPClient

type KakaHTTPClientImpl 

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

func (*KakaHTTPClientImpl) Debug 

func (c *KakaHTTPClientImpl) Debug(ctx context.Context, in *DebugRequest, opts ...http.CallOption) (*DebugReply, error)

type KakaHTTPServer 

type KakaHTTPServer interface {
	Debug(context.Context, *DebugRequest) (*DebugReply, error)
}

type KakaServer 

type KakaServer interface {
	Debug(context.Context, *DebugRequest) (*DebugReply, error)
	// contains filtered or unexported methods
}

KakaServer is the server API for Kaka service. All implementations must embed UnimplementedKakaServer for forward compatibility

type Session 

type Session struct {
	Id          string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Addr        string    `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Interleaved bool      `protobuf:"varint,3,opt,name=interleaved,proto3" json:"interleaved,omitempty"`
	Status      string    `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	Rx          uint32    `protobuf:"varint,5,opt,name=rx,proto3" json:"rx,omitempty"`
	Tx          uint32    `protobuf:"varint,6,opt,name=tx,proto3" json:"tx,omitempty"`
	Streams     []*Stream `protobuf:"bytes,7,rep,name=streams,proto3" json:"streams,omitempty"`
	// contains filtered or unexported fields
}

func (*Session) Descriptor deprecated 

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

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetAddr 

func (x *Session) GetAddr() string

func (*Session) GetId 

func (x *Session) GetId() string

func (*Session) GetInterleaved 

func (x *Session) GetInterleaved() bool

func (*Session) GetRx 

func (x *Session) GetRx() uint32

func (*Session) GetStatus 

func (x *Session) GetStatus() string

func (*Session) GetStreams 

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

func (*Session) GetTx 

func (x *Session) GetTx() uint32

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 Stream 

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

func (*Stream) Descriptor deprecated 

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

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetId 

func (x *Stream) GetId() uint32

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 UnimplementedKakaServer 

type UnimplementedKakaServer struct {
}

UnimplementedKakaServer must be embedded to have forward compatible implementations.

func (UnimplementedKakaServer) Debug 

func (UnimplementedKakaServer) Debug(context.Context, *DebugRequest) (*DebugReply, error)

type UnsafeKakaServer 

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

UnsafeKakaServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KakaServer 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.