pb

package
v0.0.0-...-a3a5c94 Latest Latest
Warning

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

Go to latest
Published: Aug 21, 2021 License: MIT 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL