api

package
v0.0.0-...-b0f4c4c Latest Latest
Warning

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

 Go to latest Published: May 3, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Execution_State_name = map[int32]string{
	0: "UNDEFINED",
	1: "CREATED",
	2: "FETCHING",
	3: "FINISHED",
	4: "ABORTED",
	5: "FAILED",
}
View Source 
var Execution_State_value = map[string]int32{
	"UNDEFINED": 0,
	"CREATED":   1,
	"FETCHING":  2,
	"FINISHED":  3,
	"ABORTED":   4,
	"FAILED":    5,
}

Functions

func RegisterAgentServer 

func RegisterAgentServer(s *grpc.Server, srv AgentServer)

func RegisterWorkerServer 

func RegisterWorkerServer(s *grpc.Server, srv WorkerServer)

Types

type AgentClient 

type AgentClient interface {
	Do(ctx context.Context, in *DoJobRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

AgentClient is the client API for Agent service.

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

func NewAgentClient 

func NewAgentClient(cc *grpc.ClientConn) AgentClient

type AgentServer 

type AgentServer interface {
	Do(context.Context, *DoJobRequest) (*empty.Empty, error)
}

AgentServer is the server API for Agent service.

type DoJobRequest 

type DoJobRequest struct {
	Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Seed                 *Seed    `protobuf:"bytes,2,opt,name=seed,proto3" json:"seed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DoJobRequest) Descriptor 

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

func (*DoJobRequest) GetJob 

func (m *DoJobRequest) GetJob() *Job

func (*DoJobRequest) GetSeed 

func (m *DoJobRequest) GetSeed() *Seed

func (*DoJobRequest) ProtoMessage 

func (*DoJobRequest) ProtoMessage()

func (*DoJobRequest) Reset 

func (m *DoJobRequest) Reset()

func (*DoJobRequest) String 

func (m *DoJobRequest) String() string

func (*DoJobRequest) XXX_DiscardUnknown 

func (m *DoJobRequest) XXX_DiscardUnknown()

func (*DoJobRequest) XXX_Marshal 

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

func (*DoJobRequest) XXX_Merge 

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

func (*DoJobRequest) XXX_Size 

func (m *DoJobRequest) XXX_Size() int

func (*DoJobRequest) XXX_Unmarshal 

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

type Entity 

type Entity struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Meta                 *Meta    `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Entity) Descriptor 

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

func (*Entity) GetId 

func (m *Entity) GetId() string

func (*Entity) GetMeta 

func (m *Entity) GetMeta() *Meta

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) Reset 

func (m *Entity) Reset()

func (*Entity) String 

func (m *Entity) String() string

func (*Entity) XXX_DiscardUnknown 

func (m *Entity) XXX_DiscardUnknown()

func (*Entity) XXX_Marshal 

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

func (*Entity) XXX_Merge 

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

func (*Entity) XXX_Size 

func (m *Entity) XXX_Size() int

func (*Entity) XXX_Unmarshal 

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

type Execution 

type Execution struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State                Execution_State      `protobuf:"varint,2,opt,name=state,proto3,enum=api.Execution_State" json:"state,omitempty"`
	JobId                string               `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	SeedId               string               `protobuf:"bytes,4,opt,name=seed_id,json=seedId,proto3" json:"seed_id,omitempty"`
	StartTime            *timestamp.Timestamp `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime              *timestamp.Timestamp `protobuf:"bytes,7,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Statuses             int32                `protobuf:"varint,8,opt,name=statuses,proto3" json:"statuses,omitempty"`
	Error                string               `protobuf:"bytes,15,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Execution) Descriptor 

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

func (*Execution) GetEndTime 

func (m *Execution) GetEndTime() *timestamp.Timestamp

func (*Execution) GetError 

func (m *Execution) GetError() string

func (*Execution) GetId 

func (m *Execution) GetId() string

func (*Execution) GetJobId 

func (m *Execution) GetJobId() string

func (*Execution) GetSeedId 

func (m *Execution) GetSeedId() string

func (*Execution) GetStartTime 

func (m *Execution) GetStartTime() *timestamp.Timestamp

func (*Execution) GetState 

func (m *Execution) GetState() Execution_State

func (*Execution) GetStatuses 

func (m *Execution) GetStatuses() int32

func (*Execution) ProtoMessage 

func (*Execution) ProtoMessage()

func (*Execution) Reset 

func (m *Execution) Reset()

func (*Execution) String 

func (m *Execution) String() string

func (*Execution) XXX_DiscardUnknown 

func (m *Execution) XXX_DiscardUnknown()

func (*Execution) XXX_Marshal 

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

func (*Execution) XXX_Merge 

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

func (*Execution) XXX_Size 

func (m *Execution) XXX_Size() int

func (*Execution) XXX_Unmarshal 

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

type Execution_State 

type Execution_State int32
const (
	Execution_UNDEFINED Execution_State = 0
	Execution_CREATED   Execution_State = 1
	Execution_FETCHING  Execution_State = 2
	Execution_FINISHED  Execution_State = 3
	Execution_ABORTED   Execution_State = 4
	Execution_FAILED    Execution_State = 5
)

func (Execution_State) EnumDescriptor 

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

func (Execution_State) String 

func (x Execution_State) String() string

type Job 

type Job struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Meta                 *Meta                `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	CronExpression       string               `protobuf:"bytes,3,opt,name=cron_expression,json=cronExpression,proto3" json:"cron_expression,omitempty"`
	ValidFrom            *timestamp.Timestamp `protobuf:"bytes,4,opt,name=valid_from,json=validFrom,proto3" json:"valid_from,omitempty"`
	ValidTo              *timestamp.Timestamp `protobuf:"bytes,5,opt,name=valid_to,json=validTo,proto3" json:"valid_to,omitempty"`
	Disabled             bool                 `protobuf:"varint,15,opt,name=disabled,proto3" json:"disabled,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Job) Descriptor 

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

func (*Job) GetCronExpression 

func (m *Job) GetCronExpression() string

func (*Job) GetDisabled 

func (m *Job) GetDisabled() bool

func (*Job) GetId 

func (m *Job) GetId() string

func (*Job) GetMeta 

func (m *Job) GetMeta() *Meta

func (*Job) GetValidFrom 

func (m *Job) GetValidFrom() *timestamp.Timestamp

func (*Job) GetValidTo 

func (m *Job) GetValidTo() *timestamp.Timestamp

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) String 

func (m *Job) String() string

func (*Job) XXX_DiscardUnknown 

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal 

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

func (*Job) XXX_Merge 

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

func (*Job) XXX_Size 

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal 

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

type Label 

type Label struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Label) Descriptor 

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

func (*Label) GetKey 

func (m *Label) GetKey() string

func (*Label) GetValue 

func (m *Label) GetValue() string

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) Reset 

func (m *Label) Reset()

func (*Label) String 

func (m *Label) String() string

func (*Label) XXX_DiscardUnknown 

func (m *Label) XXX_DiscardUnknown()

func (*Label) XXX_Marshal 

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

func (*Label) XXX_Merge 

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

func (*Label) XXX_Size 

func (m *Label) XXX_Size() int

func (*Label) XXX_Unmarshal 

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

type Meta 

type Meta struct {
	Name                 string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description          string               `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Created              *timestamp.Timestamp `protobuf:"bytes,3,opt,name=created,proto3" json:"created,omitempty"`
	CreatedBy            string               `protobuf:"bytes,4,opt,name=created_by,json=createdBy,proto3" json:"created_by,omitempty"`
	LastModified         *timestamp.Timestamp `protobuf:"bytes,5,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"`
	LastModifiedBy       string               `protobuf:"bytes,6,opt,name=last_modified_by,json=lastModifiedBy,proto3" json:"last_modified_by,omitempty"`
	Label                []*Label             `protobuf:"bytes,7,rep,name=label,proto3" json:"label,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Meta) Descriptor 

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

func (*Meta) GetCreated 

func (m *Meta) GetCreated() *timestamp.Timestamp

func (*Meta) GetCreatedBy 

func (m *Meta) GetCreatedBy() string

func (*Meta) GetDescription 

func (m *Meta) GetDescription() string

func (*Meta) GetLabel 

func (m *Meta) GetLabel() []*Label

func (*Meta) GetLastModified 

func (m *Meta) GetLastModified() *timestamp.Timestamp

func (*Meta) GetLastModifiedBy 

func (m *Meta) GetLastModifiedBy() string

func (*Meta) GetName 

func (m *Meta) GetName() string

func (*Meta) ProtoMessage 

func (*Meta) ProtoMessage()

func (*Meta) Reset 

func (m *Meta) Reset()

func (*Meta) String 

func (m *Meta) String() string

func (*Meta) XXX_DiscardUnknown 

func (m *Meta) XXX_DiscardUnknown()

func (*Meta) XXX_Marshal 

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

func (*Meta) XXX_Merge 

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

func (*Meta) XXX_Size 

func (m *Meta) XXX_Size() int

func (*Meta) XXX_Unmarshal 

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

type Parameter 

type Parameter struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Query                string   `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	MaxId                string   `protobuf:"bytes,4,opt,name=max_id,json=maxId,proto3" json:"max_id,omitempty"`
	SinceId              string   `protobuf:"bytes,5,opt,name=since_id,json=sinceId,proto3" json:"since_id,omitempty"`
	Geocode              string   `protobuf:"bytes,6,opt,name=geocode,proto3" json:"geocode,omitempty"`
	Lang                 string   `protobuf:"bytes,7,opt,name=lang,proto3" json:"lang,omitempty"`
	ResultType           string   `protobuf:"bytes,8,opt,name=result_type,json=resultType,proto3" json:"result_type,omitempty"`
	Count                int32    `protobuf:"varint,9,opt,name=count,proto3" json:"count,omitempty"`
	Until                string   `protobuf:"bytes,10,opt,name=until,proto3" json:"until,omitempty"`
	IncludeEntities      bool     `protobuf:"varint,11,opt,name=include_entities,json=includeEntities,proto3" json:"include_entities,omitempty"`
	TweetMode            string   `protobuf:"bytes,12,opt,name=tweet_mode,json=tweetMode,proto3" json:"tweet_mode,omitempty"`
	Locale               string   `protobuf:"bytes,13,opt,name=locale,proto3" json:"locale,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Parameter) Descriptor 

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

func (*Parameter) GetCount 

func (m *Parameter) GetCount() int32

func (*Parameter) GetGeocode 

func (m *Parameter) GetGeocode() string

func (*Parameter) GetId 

func (m *Parameter) GetId() string

func (*Parameter) GetIncludeEntities 

func (m *Parameter) GetIncludeEntities() bool

func (*Parameter) GetLang 

func (m *Parameter) GetLang() string

func (*Parameter) GetLocale 

func (m *Parameter) GetLocale() string

func (*Parameter) GetMaxId 

func (m *Parameter) GetMaxId() string

func (*Parameter) GetQuery 

func (m *Parameter) GetQuery() string

func (*Parameter) GetResultType 

func (m *Parameter) GetResultType() string

func (*Parameter) GetSinceId 

func (m *Parameter) GetSinceId() string

func (*Parameter) GetTweetMode 

func (m *Parameter) GetTweetMode() string

func (*Parameter) GetUntil 

func (m *Parameter) GetUntil() string

func (*Parameter) ProtoMessage 

func (*Parameter) ProtoMessage()

func (*Parameter) Reset 

func (m *Parameter) Reset()

func (*Parameter) String 

func (m *Parameter) String() string

func (*Parameter) XXX_DiscardUnknown 

func (m *Parameter) XXX_DiscardUnknown()

func (*Parameter) XXX_Marshal 

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

func (*Parameter) XXX_Merge 

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

func (*Parameter) XXX_Size 

func (m *Parameter) XXX_Size() int

func (*Parameter) XXX_Unmarshal 

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

type QueuedSeed 

type QueuedSeed struct {
	Id                   string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Seq                  int32      `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"`
	ExecutionId          string     `protobuf:"bytes,3,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	SeedId               string     `protobuf:"bytes,4,opt,name=seed_id,json=seedId,proto3" json:"seed_id,omitempty"`
	Parameter            *Parameter `protobuf:"bytes,5,opt,name=parameter,proto3" json:"parameter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*QueuedSeed) Descriptor 

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

func (*QueuedSeed) GetExecutionId 

func (m *QueuedSeed) GetExecutionId() string

func (*QueuedSeed) GetId 

func (m *QueuedSeed) GetId() string

func (*QueuedSeed) GetParameter 

func (m *QueuedSeed) GetParameter() *Parameter

func (*QueuedSeed) GetSeedId 

func (m *QueuedSeed) GetSeedId() string

func (*QueuedSeed) GetSeq 

func (m *QueuedSeed) GetSeq() int32

func (*QueuedSeed) ProtoMessage 

func (*QueuedSeed) ProtoMessage()

func (*QueuedSeed) Reset 

func (m *QueuedSeed) Reset()

func (*QueuedSeed) String 

func (m *QueuedSeed) String() string

func (*QueuedSeed) XXX_DiscardUnknown 

func (m *QueuedSeed) XXX_DiscardUnknown()

func (*QueuedSeed) XXX_Marshal 

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

func (*QueuedSeed) XXX_Merge 

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

func (*QueuedSeed) XXX_Size 

func (m *QueuedSeed) XXX_Size() int

func (*QueuedSeed) XXX_Unmarshal 

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

type RateLimit 

type RateLimit struct {
	Limit                int32                `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Remaining            int32                `protobuf:"varint,2,opt,name=remaining,proto3" json:"remaining,omitempty"`
	Reset_               *timestamp.Timestamp `protobuf:"bytes,3,opt,name=reset,proto3" json:"reset,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*RateLimit) Descriptor 

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

func (*RateLimit) GetLimit 

func (m *RateLimit) GetLimit() int32

func (*RateLimit) GetRemaining 

func (m *RateLimit) GetRemaining() int32

func (*RateLimit) GetReset_ 

func (m *RateLimit) GetReset_() *timestamp.Timestamp

func (*RateLimit) ProtoMessage 

func (*RateLimit) ProtoMessage()

func (*RateLimit) Reset 

func (m *RateLimit) Reset()

func (*RateLimit) String 

func (m *RateLimit) String() string

func (*RateLimit) XXX_DiscardUnknown 

func (m *RateLimit) XXX_DiscardUnknown()

func (*RateLimit) XXX_Marshal 

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

func (*RateLimit) XXX_Merge 

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

func (*RateLimit) XXX_Size 

func (m *RateLimit) XXX_Size() int

func (*RateLimit) XXX_Unmarshal 

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

type Seed 

type Seed struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Meta                 *Meta    `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	EntityId             string   `protobuf:"bytes,3,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"`
	JobId                []string `protobuf:"bytes,4,rep,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Disabled             bool     `protobuf:"varint,15,opt,name=disabled,proto3" json:"disabled,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Seed) Descriptor 

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

func (*Seed) GetDisabled 

func (m *Seed) GetDisabled() bool

func (*Seed) GetEntityId 

func (m *Seed) GetEntityId() string

func (*Seed) GetId 

func (m *Seed) GetId() string

func (*Seed) GetJobId 

func (m *Seed) GetJobId() []string

func (*Seed) GetMeta 

func (m *Seed) GetMeta() *Meta

func (*Seed) ProtoMessage 

func (*Seed) ProtoMessage()

func (*Seed) Reset 

func (m *Seed) Reset()

func (*Seed) String 

func (m *Seed) String() string

func (*Seed) XXX_DiscardUnknown 

func (m *Seed) XXX_DiscardUnknown()

func (*Seed) XXX_Marshal 

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

func (*Seed) XXX_Merge 

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

func (*Seed) XXX_Size 

func (m *Seed) XXX_Size() int

func (*Seed) XXX_Unmarshal 

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

type WorkReply 

type WorkReply struct {
	QueuedSeed           *QueuedSeed `protobuf:"bytes,1,opt,name=queued_seed,json=queuedSeed,proto3" json:"queued_seed,omitempty"`
	Count                int32       `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	MaxId                string      `protobuf:"bytes,3,opt,name=max_id,json=maxId,proto3" json:"max_id,omitempty"`
	SinceId              string      `protobuf:"bytes,4,opt,name=since_id,json=sinceId,proto3" json:"since_id,omitempty"`
	RateLimit            *RateLimit  `protobuf:"bytes,15,opt,name=rate_limit,json=rateLimit,proto3" json:"rate_limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*WorkReply) Descriptor 

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

func (*WorkReply) GetCount 

func (m *WorkReply) GetCount() int32

func (*WorkReply) GetMaxId 

func (m *WorkReply) GetMaxId() string

func (*WorkReply) GetQueuedSeed 

func (m *WorkReply) GetQueuedSeed() *QueuedSeed

func (*WorkReply) GetRateLimit 

func (m *WorkReply) GetRateLimit() *RateLimit

func (*WorkReply) GetSinceId 

func (m *WorkReply) GetSinceId() string

func (*WorkReply) ProtoMessage 

func (*WorkReply) ProtoMessage()

func (*WorkReply) Reset 

func (m *WorkReply) Reset()

func (*WorkReply) String 

func (m *WorkReply) String() string

func (*WorkReply) XXX_DiscardUnknown 

func (m *WorkReply) XXX_DiscardUnknown()

func (*WorkReply) XXX_Marshal 

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

func (*WorkReply) XXX_Merge 

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

func (*WorkReply) XXX_Size 

func (m *WorkReply) XXX_Size() int

func (*WorkReply) XXX_Unmarshal 

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

type WorkRequest 

type WorkRequest struct {
	QueuedSeed           *QueuedSeed `protobuf:"bytes,1,opt,name=queued_seed,json=queuedSeed,proto3" json:"queued_seed,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*WorkRequest) Descriptor 

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

func (*WorkRequest) GetQueuedSeed 

func (m *WorkRequest) GetQueuedSeed() *QueuedSeed

func (*WorkRequest) ProtoMessage 

func (*WorkRequest) ProtoMessage()

func (*WorkRequest) Reset 

func (m *WorkRequest) Reset()

func (*WorkRequest) String 

func (m *WorkRequest) String() string

func (*WorkRequest) XXX_DiscardUnknown 

func (m *WorkRequest) XXX_DiscardUnknown()

func (*WorkRequest) XXX_Marshal 

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

func (*WorkRequest) XXX_Merge 

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

func (*WorkRequest) XXX_Size 

func (m *WorkRequest) XXX_Size() int

func (*WorkRequest) XXX_Unmarshal 

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

type WorkerClient 

type WorkerClient interface {
	Do(ctx context.Context, in *WorkRequest, opts ...grpc.CallOption) (*WorkReply, error)
}

WorkerClient is the client API for Worker service.

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

func NewWorkerClient 

func NewWorkerClient(cc *grpc.ClientConn) WorkerClient

type WorkerServer 

type WorkerServer interface {
	Do(context.Context, *WorkRequest) (*WorkReply, error)
}

WorkerServer is the server API for Worker service.

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.