protoMq

package
v1.0.3 Latest Latest
Warning

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

 Go to latest Published: Apr 9, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Mq_PushData_FullMethodName = "/Mq/PushData"
	Mq_PullData_FullMethodName = "/Mq/PullData"
)

Variables

View Source 
var (
	DataType_name = map[int32]string{
		0: "DataOnly",
		1: "DataEnd",
		2: "EndOnly",
	}
	DataType_value = map[string]int32{
		"DataOnly": 0,
		"DataEnd":  1,
		"EndOnly":  2,
	}
)

Enum value maps for DataType.

View Source 
var (
	BKType_name = map[int32]string{
		0: "RemoteSaved",
		1: "RemoteDefaultNow",
		2: "RemoteDefaultAll",
		3: "UserSet",
	}
	BKType_value = map[string]int32{
		"RemoteSaved":      0,
		"RemoteDefaultNow": 1,
		"RemoteDefaultAll": 2,
		"UserSet":          3,
	}
)

Enum value maps for BKType.

View Source 
var File_mq_proto protoreflect.FileDescriptor
View Source 
var Mq_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Mq",
	HandlerType: (*MqServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PushData",
			Handler:       _Mq_PushData_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "PullData",
			Handler:       _Mq_PullData_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "mq.proto",
}

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

Functions

func RegisterMqServer 

func RegisterMqServer(s grpc.ServiceRegistrar, srv MqServer)

Types

type BKType added in v1.0.2 

type BKType int32
const (
	BKType_RemoteSaved      BKType = 0 // 使用远端位置，没有则报错
	BKType_RemoteDefaultNow BKType = 1 // 使用远端位置,没有则使用当前位置
	BKType_RemoteDefaultAll BKType = 2 // 使用远端位置,没有读取出所有的
	BKType_UserSet          BKType = 3 // 使用指定位置
)

func (BKType) Descriptor added in v1.0.2 

func (BKType) Descriptor() protoreflect.EnumDescriptor

func (BKType) Enum added in v1.0.2 

func (x BKType) Enum() *BKType

func (BKType) EnumDescriptor deprecated added in v1.0.2 

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

Deprecated: Use BKType.Descriptor instead.

func (BKType) Number added in v1.0.2 

func (x BKType) Number() protoreflect.EnumNumber

func (BKType) String added in v1.0.2 

func (x BKType) String() string

func (BKType) Type added in v1.0.2 

func (BKType) Type() protoreflect.EnumType

type DataType added in v1.0.2 

type DataType int32
const (
	DataType_DataOnly DataType = 0 // 仅数据
	DataType_DataEnd  DataType = 1 // 数据和结束符
	DataType_EndOnly  DataType = 2 // 仅结束符
)

func (DataType) Descriptor added in v1.0.2 

func (DataType) Descriptor() protoreflect.EnumDescriptor

func (DataType) Enum added in v1.0.2 

func (x DataType) Enum() *DataType

func (DataType) EnumDescriptor deprecated added in v1.0.2 

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

Deprecated: Use DataType.Descriptor instead.

func (DataType) Number added in v1.0.2 

func (x DataType) Number() protoreflect.EnumNumber

func (DataType) String added in v1.0.2 

func (x DataType) String() string

func (DataType) Type added in v1.0.2 

func (DataType) Type() protoreflect.EnumType

type MqClient 

type MqClient interface {
	PushData(ctx context.Context, opts ...grpc.CallOption) (Mq_PushDataClient, error)
	PullData(ctx context.Context, in *ReqPullData, opts ...grpc.CallOption) (Mq_PullDataClient, error)
}

MqClient is the client API for Mq 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 NewMqClient 

func NewMqClient(cc grpc.ClientConnInterface) MqClient

type MqServer 

type MqServer interface {
	PushData(Mq_PushDataServer) error
	PullData(*ReqPullData, Mq_PullDataServer) error
	// contains filtered or unexported methods
}

MqServer is the server API for Mq service. All implementations must embed UnimplementedMqServer for forward compatibility

type Mq_PullDataClient 

type Mq_PullDataClient interface {
	Recv() (*ResPullData, error)
	grpc.ClientStream
}

type Mq_PullDataServer 

type Mq_PullDataServer interface {
	Send(*ResPullData) error
	grpc.ServerStream
}

type Mq_PushDataClient 

type Mq_PushDataClient interface {
	Send(*ReqPushData) error
	Recv() (*ResPushData, error)
	grpc.ClientStream
}

type Mq_PushDataServer 

type Mq_PushDataServer interface {
	Send(*ResPushData) error
	Recv() (*ReqPushData, error)
	grpc.ServerStream
}

type ReqPullData 

type ReqPullData struct {
	User   string `protobuf:"bytes,1,opt,name=User,proto3" json:"User,omitempty"`                  // 用户
	Ch     string `protobuf:"bytes,2,opt,name=Ch,proto3" json:"Ch,omitempty"`                      // 频道
	BKType BKType `protobuf:"varint,3,opt,name=BKType,proto3,enum=BKType" json:"BKType,omitempty"` // bucket参数类型
	BKName string `protobuf:"bytes,4,opt,name=BKName,proto3" json:"BKName,omitempty"`              // bucket name
	BKKey  string `protobuf:"bytes,5,opt,name=BKKey,proto3" json:"BKKey,omitempty"`                // bucket key
	// contains filtered or unexported fields
}

拉取数据参数

func (*ReqPullData) Descriptor deprecated 

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

Deprecated: Use ReqPullData.ProtoReflect.Descriptor instead.

func (*ReqPullData) GetBKKey 

func (x *ReqPullData) GetBKKey() string

func (*ReqPullData) GetBKName 

func (x *ReqPullData) GetBKName() string

func (*ReqPullData) GetBKType 

func (x *ReqPullData) GetBKType() BKType

func (*ReqPullData) GetCh 

func (x *ReqPullData) GetCh() string

func (*ReqPullData) GetUser 

func (x *ReqPullData) GetUser() string

func (*ReqPullData) ProtoMessage 

func (*ReqPullData) ProtoMessage()

func (*ReqPullData) ProtoReflect 

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

func (*ReqPullData) Reset 

func (x *ReqPullData) Reset()

func (*ReqPullData) String 

func (x *ReqPullData) String() string

type ReqPushData 

type ReqPushData struct {
	DataType DataType `protobuf:"varint,1,opt,name=DataType,proto3,enum=DataType" json:"DataType,omitempty"` // 数据说明
	Ch       string   `protobuf:"bytes,2,opt,name=Ch,proto3" json:"Ch,omitempty"`                            // 频道
	Data     []byte   `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`                        // 数据内容
	// contains filtered or unexported fields
}

推送数据参数

func (*ReqPushData) Descriptor deprecated 

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

Deprecated: Use ReqPushData.ProtoReflect.Descriptor instead.

func (*ReqPushData) GetCh 

func (x *ReqPushData) GetCh() string

func (*ReqPushData) GetData 

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

func (*ReqPushData) GetDataType added in v1.0.2 

func (x *ReqPushData) GetDataType() DataType

func (*ReqPushData) ProtoMessage 

func (*ReqPushData) ProtoMessage()

func (*ReqPushData) ProtoReflect 

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

func (*ReqPushData) Reset 

func (x *ReqPushData) Reset()

func (*ReqPushData) String 

func (x *ReqPushData) String() string

type ResPullData 

type ResPullData struct {
	ErrNum int32  `protobuf:"varint,1,opt,name=ErrNum,proto3" json:"ErrNum,omitempty"` // 错误编号，0为正常
	BKName string `protobuf:"bytes,2,opt,name=BKName,proto3" json:"BKName,omitempty"`  // bucket name
	BKKey  string `protobuf:"bytes,3,opt,name=BKKey,proto3" json:"BKKey,omitempty"`    // bucket key
	Data   []byte `protobuf:"bytes,4,opt,name=Data,proto3" json:"Data,omitempty"`      // 数据内容
	// contains filtered or unexported fields
}

拉取数据返回

func (*ResPullData) Descriptor deprecated 

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

Deprecated: Use ResPullData.ProtoReflect.Descriptor instead.

func (*ResPullData) GetBKKey 

func (x *ResPullData) GetBKKey() string

func (*ResPullData) GetBKName 

func (x *ResPullData) GetBKName() string

func (*ResPullData) GetData 

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

func (*ResPullData) GetErrNum 

func (x *ResPullData) GetErrNum() int32

func (*ResPullData) ProtoMessage 

func (*ResPullData) ProtoMessage()

func (*ResPullData) ProtoReflect 

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

func (*ResPullData) Reset 

func (x *ResPullData) Reset()

func (*ResPullData) String 

func (x *ResPullData) String() string

type ResPushData 

type ResPushData struct {
	ErrNum int32 `protobuf:"varint,1,opt,name=ErrNum,proto3" json:"ErrNum,omitempty"` // 错误编号，0为正常
	// contains filtered or unexported fields
}

推送数据返回

func (*ResPushData) Descriptor deprecated 

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

Deprecated: Use ResPushData.ProtoReflect.Descriptor instead.

func (*ResPushData) GetErrNum 

func (x *ResPushData) GetErrNum() int32

func (*ResPushData) ProtoMessage 

func (*ResPushData) ProtoMessage()

func (*ResPushData) ProtoReflect 

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

func (*ResPushData) Reset 

func (x *ResPushData) Reset()

func (*ResPushData) String 

func (x *ResPushData) String() string

type UnimplementedMqServer 

type UnimplementedMqServer struct {
}

UnimplementedMqServer must be embedded to have forward compatible implementations.

func (UnimplementedMqServer) PullData 

func (UnimplementedMqServer) PullData(*ReqPullData, Mq_PullDataServer) error

func (UnimplementedMqServer) PushData 

func (UnimplementedMqServer) PushData(Mq_PushDataServer) error

type UnsafeMqServer 

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

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