pb

package
v1.15.0 Latest Latest
Warning

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

 Go to latest Published: Sep 4, 2024 License: LGPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterTaskQueueServer 

func RegisterTaskQueueServer(s *grpc.Server, srv TaskQueueServer)

Types

type DequeueRequest 

type DequeueRequest struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	ClientHost           string   `protobuf:"bytes,2,opt,name=client_host,json=clientHost,proto3" json:"client_host,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DequeueRequest) Descriptor 

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

func (*DequeueRequest) GetClientHost 

func (m *DequeueRequest) GetClientHost() string

func (*DequeueRequest) GetTopic 

func (m *DequeueRequest) GetTopic() string

func (*DequeueRequest) ProtoMessage 

func (*DequeueRequest) ProtoMessage()

func (*DequeueRequest) Reset 

func (m *DequeueRequest) Reset()

func (*DequeueRequest) String 

func (m *DequeueRequest) String() string

func (*DequeueRequest) XXX_DiscardUnknown 

func (m *DequeueRequest) XXX_DiscardUnknown()

func (*DequeueRequest) XXX_Marshal 

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

func (*DequeueRequest) XXX_Merge 

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

func (*DequeueRequest) XXX_Size 

func (m *DequeueRequest) XXX_Size() int

func (*DequeueRequest) XXX_Unmarshal 

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

type EnqueueRequest 

type EnqueueRequest struct {
	Topic                string       `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Message              *TaskMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*EnqueueRequest) Descriptor 

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

func (*EnqueueRequest) GetMessage 

func (m *EnqueueRequest) GetMessage() *TaskMessage

func (*EnqueueRequest) GetTopic 

func (m *EnqueueRequest) GetTopic() string

func (*EnqueueRequest) ProtoMessage 

func (*EnqueueRequest) ProtoMessage()

func (*EnqueueRequest) Reset 

func (m *EnqueueRequest) Reset()

func (*EnqueueRequest) String 

func (m *EnqueueRequest) String() string

func (*EnqueueRequest) XXX_DiscardUnknown 

func (m *EnqueueRequest) XXX_DiscardUnknown()

func (*EnqueueRequest) XXX_Marshal 

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

func (*EnqueueRequest) XXX_Merge 

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

func (*EnqueueRequest) XXX_Size 

func (m *EnqueueRequest) XXX_Size() int

func (*EnqueueRequest) XXX_Unmarshal 

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

type TaskMessage 

type TaskMessage struct {
	TaskId               string   `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	TaskType             string   `protobuf:"bytes,2,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	TaskBody             []byte   `protobuf:"bytes,3,opt,name=task_body,json=taskBody,proto3" json:"task_body,omitempty"`
	CreateTime           string   `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	User                 string   `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskMessage) Descriptor 

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

func (*TaskMessage) GetCreateTime 

func (m *TaskMessage) GetCreateTime() string

func (*TaskMessage) GetTaskBody 

func (m *TaskMessage) GetTaskBody() []byte

func (*TaskMessage) GetTaskId 

func (m *TaskMessage) GetTaskId() string

func (*TaskMessage) GetTaskType 

func (m *TaskMessage) GetTaskType() string

func (*TaskMessage) GetUser 

func (m *TaskMessage) GetUser() string

func (*TaskMessage) ProtoMessage 

func (*TaskMessage) ProtoMessage()

func (*TaskMessage) Reset 

func (m *TaskMessage) Reset()

func (*TaskMessage) String 

func (m *TaskMessage) String() string

func (*TaskMessage) XXX_DiscardUnknown 

func (m *TaskMessage) XXX_DiscardUnknown()

func (*TaskMessage) XXX_Marshal 

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

func (*TaskMessage) XXX_Merge 

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

func (*TaskMessage) XXX_Size 

func (m *TaskMessage) XXX_Size() int

func (*TaskMessage) XXX_Unmarshal 

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

type TaskQueueClient 

type TaskQueueClient interface {
	Enqueue(ctx context.Context, in *EnqueueRequest, opts ...grpc.CallOption) (*TaskReply, error)
	Topics(ctx context.Context, in *TopicRequest, opts ...grpc.CallOption) (*TaskReply, error)
	Dequeue(ctx context.Context, in *DequeueRequest, opts ...grpc.CallOption) (*TaskMessage, error)
}

TaskQueueClient is the client API for TaskQueue service.

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

func NewTaskQueueClient 

func NewTaskQueueClient(cc *grpc.ClientConn) TaskQueueClient

type TaskQueueServer 

type TaskQueueServer interface {
	Enqueue(context.Context, *EnqueueRequest) (*TaskReply, error)
	Topics(context.Context, *TopicRequest) (*TaskReply, error)
	Dequeue(context.Context, *DequeueRequest) (*TaskMessage, error)
}

TaskQueueServer is the server API for TaskQueue service.

type TaskReply 

type TaskReply struct {
	Status               string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Topics               []string `protobuf:"bytes,3,rep,name=topics,proto3" json:"topics,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskReply) Descriptor 

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

func (*TaskReply) GetMessage 

func (m *TaskReply) GetMessage() string

func (*TaskReply) GetStatus 

func (m *TaskReply) GetStatus() string

func (*TaskReply) GetTopics 

func (m *TaskReply) GetTopics() []string

func (*TaskReply) ProtoMessage 

func (*TaskReply) ProtoMessage()

func (*TaskReply) Reset 

func (m *TaskReply) Reset()

func (*TaskReply) String 

func (m *TaskReply) String() string

func (*TaskReply) XXX_DiscardUnknown 

func (m *TaskReply) XXX_DiscardUnknown()

func (*TaskReply) XXX_Marshal 

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

func (*TaskReply) XXX_Merge 

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

func (*TaskReply) XXX_Size 

func (m *TaskReply) XXX_Size() int

func (*TaskReply) XXX_Unmarshal 

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

type TopicRequest 

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

func (*TopicRequest) Descriptor 

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

func (*TopicRequest) ProtoMessage 

func (*TopicRequest) ProtoMessage()

func (*TopicRequest) Reset 

func (m *TopicRequest) Reset()

func (*TopicRequest) String 

func (m *TopicRequest) String() string

func (*TopicRequest) XXX_DiscardUnknown 

func (m *TopicRequest) XXX_DiscardUnknown()

func (*TopicRequest) XXX_Marshal 

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

func (*TopicRequest) XXX_Merge 

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

func (*TopicRequest) XXX_Size 

func (m *TopicRequest) XXX_Size() int

func (*TopicRequest) XXX_Unmarshal 

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

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.