conn

Documentation

Overview

Package conn is a generated protocol buffer package.

It is generated from these files:

conn.proto

It has these top-level messages:

DisconnectReq
DisconnectResp
NotifyReq
NotifyResp

Index

• func RegisterConnServiceServer(s *grpc.Server, srv ConnServiceServer)
• type ConnServiceClient
  • func NewConnServiceClient(cc *grpc.ClientConn) ConnServiceClient
• type ConnServiceServer
• type DisconnectReq
  • func (*DisconnectReq) Descriptor() ([]byte, []int)
  • func (m *DisconnectReq) GetClientID() string
  • func (m *DisconnectReq) GetConnectionID() int64
  • func (m *DisconnectReq) GetService() string
  • func (m *DisconnectReq) GetTraceID() string
  • func (*DisconnectReq) ProtoMessage()
  • func (m *DisconnectReq) Reset()
  • func (m *DisconnectReq) String() string
• type DisconnectResp
  • func (*DisconnectResp) Descriptor() ([]byte, []int)
  • func (*DisconnectResp) ProtoMessage()
  • func (m *DisconnectResp) Reset()
  • func (m *DisconnectResp) String() string
• type NotifyReq
  • func (*NotifyReq) Descriptor() ([]byte, []int)
  • func (m *NotifyReq) GetIndex() []byte
  • func (m *NotifyReq) GetNoneDowngrade() bool
  • func (m *NotifyReq) GetService() string
  • func (m *NotifyReq) GetTopic() string
  • func (m *NotifyReq) GetTraceID() string
  • func (*NotifyReq) ProtoMessage()
  • func (m *NotifyReq) Reset()
  • func (m *NotifyReq) String() string
• type NotifyResp
  • func (*NotifyResp) Descriptor() ([]byte, []int)
  • func (*NotifyResp) ProtoMessage()
  • func (m *NotifyResp) Reset()
  • func (m *NotifyResp) String() string

Functions

func RegisterConnServiceServer

func RegisterConnServiceServer(s *grpc.Server, srv ConnServiceServer)

Types

type ConnServiceClient

type ConnServiceClient interface {
	Disconnect(ctx context.Context, in *DisconnectReq, opts ...grpc.CallOption) (*DisconnectResp, error)
	Notify(ctx context.Context, in *NotifyReq, opts ...grpc.CallOption) (*NotifyResp, error)
}

func NewConnServiceClient

func NewConnServiceClient(cc *grpc.ClientConn) ConnServiceClient

type ConnServiceServer

type ConnServiceServer interface {
	Disconnect(context.Context, *DisconnectReq) (*DisconnectResp, error)
	Notify(context.Context, *NotifyReq) (*NotifyResp, error)
}

type DisconnectReq

type DisconnectReq struct {
	ClientID     string `protobuf:"bytes,1,opt,name=ClientID" json:"ClientID,omitempty"`
	ConnectionID int64  `protobuf:"varint,2,opt,name=ConnectionID" json:"ConnectionID,omitempty"`
	TraceID      string `protobuf:"bytes,3,opt,name=TraceID" json:"TraceID,omitempty"`
	Service      string `protobuf:"bytes,4,opt,name=Service" json:"Service,omitempty"`
}

func (*DisconnectReq) Descriptor

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

func (*DisconnectReq) GetClientID

func (m *DisconnectReq) GetClientID() string

func (*DisconnectReq) GetConnectionID

func (m *DisconnectReq) GetConnectionID() int64

func (*DisconnectReq) GetService

func (m *DisconnectReq) GetService() string

func (*DisconnectReq) GetTraceID

func (m *DisconnectReq) GetTraceID() string

func (*DisconnectReq) ProtoMessage

func (*DisconnectReq) ProtoMessage()

func (*DisconnectReq) Reset

func (m *DisconnectReq) Reset()

func (*DisconnectReq) String

func (m *DisconnectReq) String() string

type DisconnectResp

type DisconnectResp struct {
}

func (*DisconnectResp) Descriptor

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

func (*DisconnectResp) ProtoMessage

func (*DisconnectResp) ProtoMessage()

func (*DisconnectResp) Reset

func (m *DisconnectResp) Reset()

func (*DisconnectResp) String

func (m *DisconnectResp) String() string

type NotifyReq

type NotifyReq struct {
	Topic         string `protobuf:"bytes,1,opt,name=Topic" json:"Topic,omitempty"`
	Index         []byte `protobuf:"bytes,2,opt,name=Index,proto3" json:"Index,omitempty"`
	NoneDowngrade bool   `protobuf:"varint,3,opt,name=NoneDowngrade" json:"NoneDowngrade,omitempty"`
	TraceID       string `protobuf:"bytes,4,opt,name=TraceID" json:"TraceID,omitempty"`
	Service       string `protobuf:"bytes,5,opt,name=Service" json:"Service,omitempty"`
}

func (*NotifyReq) Descriptor

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

func (*NotifyReq) GetIndex

func (m *NotifyReq) GetIndex() []byte

func (*NotifyReq) GetNoneDowngrade

func (m *NotifyReq) GetNoneDowngrade() bool

func (*NotifyReq) GetService

func (m *NotifyReq) GetService() string

func (*NotifyReq) GetTopic

func (m *NotifyReq) GetTopic() string

func (*NotifyReq) GetTraceID

func (m *NotifyReq) GetTraceID() string

func (*NotifyReq) ProtoMessage

func (*NotifyReq) ProtoMessage()

func (*NotifyReq) Reset

func (m *NotifyReq) Reset()

func (*NotifyReq) String

func (m *NotifyReq) String() string

type NotifyResp

type NotifyResp struct {
}

func (*NotifyResp) Descriptor

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

func (*NotifyResp) ProtoMessage

func (*NotifyResp) ProtoMessage()

func (*NotifyResp) Reset

func (m *NotifyResp) Reset()

func (*NotifyResp) String

func (m *NotifyResp) String() string