v1

package
v0.0.0-...-83adff0 Latest Latest
Warning

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

 Go to latest Published: Jul 6, 2020 License: GPL-3.0 Imports: 9 Imported by: 0

Documentation

Overview

Package v1 is a generated protocol buffer package.

It is generated from these files: 

app/interface/main/creative/api/grpc/v1/api.proto

It has these top-level messages: 

FlowRequest
FlowResponse
TaskRequest
TaskReply
Empty

Index

Constants

View Source 
const DiscoveryAppID = "main.archive.creative"

DiscoveryAppID .

Variables

View Source 
var (
	ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterCreativeServer 

func RegisterCreativeServer(s *grpc.Server, srv CreativeServer)

Types

type CreativeClient 

type CreativeClient interface {
	// FlowJudge 查询flow情况
	FlowJudge(ctx context.Context, in *FlowRequest, opts ...grpc.CallOption) (*FlowResponse, error)
	// Sends a greeting
	CheckTaskState(ctx context.Context, in *TaskRequest, opts ...grpc.CallOption) (*TaskReply, error)
	// Ping Service
	Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	// Close Service
	Close(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
}

func NewClient 

func NewClient(cfg *warden.ClientConfig, opts ...grpc.DialOption) (CreativeClient, error)

NewClient new grpc client

func NewCreativeClient 

func NewCreativeClient(cc *grpc.ClientConn) CreativeClient

type CreativeServer 

type CreativeServer interface {
	// FlowJudge 查询flow情况
	FlowJudge(context.Context, *FlowRequest) (*FlowResponse, error)
	// Sends a greeting
	CheckTaskState(context.Context, *TaskRequest) (*TaskReply, error)
	// Ping Service
	Ping(context.Context, *Empty) (*Empty, error)
	// Close Service
	Close(context.Context, *Empty) (*Empty, error)
}

type Empty 

type Empty struct {
}

func (*Empty) Descriptor 

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

func (*Empty) Marshal 

func (m *Empty) Marshal() (dAtA []byte, err error)

func (*Empty) MarshalTo 

func (m *Empty) MarshalTo(dAtA []byte) (int, error)

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) Size 

func (m *Empty) Size() (n int)

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) Unmarshal 

func (m *Empty) Unmarshal(dAtA []byte) error

type FlowRequest 

type FlowRequest struct {
	Gid      int64   `protobuf:"varint,1,opt,name=gid,proto3" json:"gid,omitempty"`
	Business int64   `protobuf:"varint,2,opt,name=business,proto3" json:"business,omitempty"`
	Oids     []int64 `protobuf:"varint,3,rep,packed,name=oids" json:"oids,omitempty"`
}

func (*FlowRequest) Descriptor 

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

func (*FlowRequest) GetBusiness 

func (m *FlowRequest) GetBusiness() int64

func (*FlowRequest) GetGid 

func (m *FlowRequest) GetGid() int64

func (*FlowRequest) GetOids 

func (m *FlowRequest) GetOids() []int64

func (*FlowRequest) Marshal 

func (m *FlowRequest) Marshal() (dAtA []byte, err error)

func (*FlowRequest) MarshalTo 

func (m *FlowRequest) MarshalTo(dAtA []byte) (int, error)

func (*FlowRequest) ProtoMessage 

func (*FlowRequest) ProtoMessage()

func (*FlowRequest) Reset 

func (m *FlowRequest) Reset()

func (*FlowRequest) Size 

func (m *FlowRequest) Size() (n int)

func (*FlowRequest) String 

func (m *FlowRequest) String() string

func (*FlowRequest) Unmarshal 

func (m *FlowRequest) Unmarshal(dAtA []byte) error

type FlowResponse 

type FlowResponse struct {
	Oids []int64 `protobuf:"varint,1,rep,packed,name=oids" json:"oids,omitempty"`
}

func (*FlowResponse) Descriptor 

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

func (*FlowResponse) GetOids 

func (m *FlowResponse) GetOids() []int64

func (*FlowResponse) Marshal 

func (m *FlowResponse) Marshal() (dAtA []byte, err error)

func (*FlowResponse) MarshalTo 

func (m *FlowResponse) MarshalTo(dAtA []byte) (int, error)

func (*FlowResponse) ProtoMessage 

func (*FlowResponse) ProtoMessage()

func (*FlowResponse) Reset 

func (m *FlowResponse) Reset()

func (*FlowResponse) Size 

func (m *FlowResponse) Size() (n int)

func (*FlowResponse) String 

func (m *FlowResponse) String() string

func (*FlowResponse) Unmarshal 

func (m *FlowResponse) Unmarshal(dAtA []byte) error

type TaskReply 

type TaskReply struct {
	FinishState bool `protobuf:"varint,1,opt,name=finish_state,json=finishState,proto3" json:"finish_state,omitempty"`
}

The response message containing the greetings

func (*TaskReply) Descriptor 

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

func (*TaskReply) GetFinishState 

func (m *TaskReply) GetFinishState() bool

func (*TaskReply) Marshal 

func (m *TaskReply) Marshal() (dAtA []byte, err error)

func (*TaskReply) MarshalTo 

func (m *TaskReply) MarshalTo(dAtA []byte) (int, error)

func (*TaskReply) ProtoMessage 

func (*TaskReply) ProtoMessage()

func (*TaskReply) Reset 

func (m *TaskReply) Reset()

func (*TaskReply) Size 

func (m *TaskReply) Size() (n int)

func (*TaskReply) String 

func (m *TaskReply) String() string

func (*TaskReply) Unmarshal 

func (m *TaskReply) Unmarshal(dAtA []byte) error

type TaskRequest 

type TaskRequest struct {
	Mid    int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"`
	TaskId int64 `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
}

The request message containing the user's name.

func (*TaskRequest) Descriptor 

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

func (*TaskRequest) GetMid 

func (m *TaskRequest) GetMid() int64

func (*TaskRequest) GetTaskId 

func (m *TaskRequest) GetTaskId() int64

func (*TaskRequest) Marshal 

func (m *TaskRequest) Marshal() (dAtA []byte, err error)

func (*TaskRequest) MarshalTo 

func (m *TaskRequest) MarshalTo(dAtA []byte) (int, error)

func (*TaskRequest) ProtoMessage 

func (*TaskRequest) ProtoMessage()

func (*TaskRequest) Reset 

func (m *TaskRequest) Reset()

func (*TaskRequest) Size 

func (m *TaskRequest) Size() (n int)

func (*TaskRequest) String 

func (m *TaskRequest) String() string

func (*TaskRequest) Unmarshal 

func (m *TaskRequest) Unmarshal(dAtA []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.