rainbond: github.com/goodrain/rainbond/mq/api/grpc/pb Index | Files

package pb

import "github.com/goodrain/rainbond/mq/api/grpc/pb"

Index

Package Files

message.pb.go

func RegisterTaskQueueServer Uses

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

type DequeueRequest Uses

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 Uses

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

func (*DequeueRequest) GetClientHost Uses

func (m *DequeueRequest) GetClientHost() string

func (*DequeueRequest) GetTopic Uses

func (m *DequeueRequest) GetTopic() string

func (*DequeueRequest) ProtoMessage Uses

func (*DequeueRequest) ProtoMessage()

func (*DequeueRequest) Reset Uses

func (m *DequeueRequest) Reset()

func (*DequeueRequest) String Uses

func (m *DequeueRequest) String() string

func (*DequeueRequest) XXX_DiscardUnknown Uses

func (m *DequeueRequest) XXX_DiscardUnknown()

func (*DequeueRequest) XXX_Marshal Uses

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

func (*DequeueRequest) XXX_Merge Uses

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

func (*DequeueRequest) XXX_Size Uses

func (m *DequeueRequest) XXX_Size() int

func (*DequeueRequest) XXX_Unmarshal Uses

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

type EnqueueRequest Uses

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 Uses

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

func (*EnqueueRequest) GetMessage Uses

func (m *EnqueueRequest) GetMessage() *TaskMessage

func (*EnqueueRequest) GetTopic Uses

func (m *EnqueueRequest) GetTopic() string

func (*EnqueueRequest) ProtoMessage Uses

func (*EnqueueRequest) ProtoMessage()

func (*EnqueueRequest) Reset Uses

func (m *EnqueueRequest) Reset()

func (*EnqueueRequest) String Uses

func (m *EnqueueRequest) String() string

func (*EnqueueRequest) XXX_DiscardUnknown Uses

func (m *EnqueueRequest) XXX_DiscardUnknown()

func (*EnqueueRequest) XXX_Marshal Uses

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

func (*EnqueueRequest) XXX_Merge Uses

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

func (*EnqueueRequest) XXX_Size Uses

func (m *EnqueueRequest) XXX_Size() int

func (*EnqueueRequest) XXX_Unmarshal Uses

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

type TaskMessage Uses

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 Uses

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

func (*TaskMessage) GetCreateTime Uses

func (m *TaskMessage) GetCreateTime() string

func (*TaskMessage) GetTaskBody Uses

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

func (*TaskMessage) GetTaskId Uses

func (m *TaskMessage) GetTaskId() string

func (*TaskMessage) GetTaskType Uses

func (m *TaskMessage) GetTaskType() string

func (*TaskMessage) GetUser Uses

func (m *TaskMessage) GetUser() string

func (*TaskMessage) ProtoMessage Uses

func (*TaskMessage) ProtoMessage()

func (*TaskMessage) Reset Uses

func (m *TaskMessage) Reset()

func (*TaskMessage) String Uses

func (m *TaskMessage) String() string

func (*TaskMessage) XXX_DiscardUnknown Uses

func (m *TaskMessage) XXX_DiscardUnknown()

func (*TaskMessage) XXX_Marshal Uses

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

func (*TaskMessage) XXX_Merge Uses

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

func (*TaskMessage) XXX_Size Uses

func (m *TaskMessage) XXX_Size() int

func (*TaskMessage) XXX_Unmarshal Uses

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

type TaskQueueClient Uses

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 Uses

func NewTaskQueueClient(cc *grpc.ClientConn) TaskQueueClient

type TaskQueueServer Uses

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 Uses

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 Uses

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

func (*TaskReply) GetMessage Uses

func (m *TaskReply) GetMessage() string

func (*TaskReply) GetStatus Uses

func (m *TaskReply) GetStatus() string

func (*TaskReply) GetTopics Uses

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

func (*TaskReply) ProtoMessage Uses

func (*TaskReply) ProtoMessage()

func (*TaskReply) Reset Uses

func (m *TaskReply) Reset()

func (*TaskReply) String Uses

func (m *TaskReply) String() string

func (*TaskReply) XXX_DiscardUnknown Uses

func (m *TaskReply) XXX_DiscardUnknown()

func (*TaskReply) XXX_Marshal Uses

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

func (*TaskReply) XXX_Merge Uses

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

func (*TaskReply) XXX_Size Uses

func (m *TaskReply) XXX_Size() int

func (*TaskReply) XXX_Unmarshal Uses

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

type TopicRequest Uses

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

func (*TopicRequest) Descriptor Uses

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

func (*TopicRequest) ProtoMessage Uses

func (*TopicRequest) ProtoMessage()

func (*TopicRequest) Reset Uses

func (m *TopicRequest) Reset()

func (*TopicRequest) String Uses

func (m *TopicRequest) String() string

func (*TopicRequest) XXX_DiscardUnknown Uses

func (m *TopicRequest) XXX_DiscardUnknown()

func (*TopicRequest) XXX_Marshal Uses

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

func (*TopicRequest) XXX_Merge Uses

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

func (*TopicRequest) XXX_Size Uses

func (m *TopicRequest) XXX_Size() int

func (*TopicRequest) XXX_Unmarshal Uses

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

Package pb imports 5 packages (graph) and is imported by 9 packages. Updated 2019-07-08. Refresh now. Tools for package owners.