agent

Documentation

Index

• func RegisterAgentServer(s *grpc.Server, srv AgentServer)
• type AgentClient
  • func NewAgentClient(cc *grpc.ClientConn) AgentClient
• type AgentServer
• type Job
  • func (*Job) Descriptor() ([]byte, []int)
  • func (m *Job) GetContainer() string
  • func (m *Job) GetDuration() uint32
  • func (m *Job) GetName() string
  • func (m *Job) GetUsers() uint32
  • func (*Job) ProtoMessage()
  • func (m *Job) Reset()
  • func (m *Job) String() string
  • func (m *Job) XXX_DiscardUnknown()
  • func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Job) XXX_Merge(src proto.Message)
  • func (m *Job) XXX_Size() int
  • func (m *Job) XXX_Unmarshal(b []byte) error
• type Payload
  • func (*Payload) Descriptor() ([]byte, []int)
  • func (m *Payload) GetJob() *Job
  • func (m *Payload) GetVersion() string
  • func (*Payload) ProtoMessage()
  • func (m *Payload) Reset()
  • func (m *Payload) String() string
  • func (m *Payload) XXX_DiscardUnknown()
  • func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Payload) XXX_Merge(src proto.Message)
  • func (m *Payload) XXX_Size() int
  • func (m *Payload) XXX_Unmarshal(b []byte) error
• type Response
  • func (*Response) Descriptor() ([]byte, []int)
  • func (m *Response) GetError() bool
  • func (m *Response) GetOutput() string
  • func (*Response) ProtoMessage()
  • func (m *Response) Reset()
  • func (m *Response) String() string
  • func (m *Response) XXX_DiscardUnknown()
  • func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Response) XXX_Merge(src proto.Message)
  • func (m *Response) XXX_Size() int
  • func (m *Response) XXX_Unmarshal(b []byte) error
• type UnimplementedAgentServer
  • func (*UnimplementedAgentServer) Create(ctx context.Context, req *Payload) (*Response, error)

Functions

func RegisterAgentServer

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

Types

type AgentClient

type AgentClient interface {
	Create(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Response, 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 {
	Create(context.Context, *Payload) (*Response, error)
}

AgentServer is the server API for Agent service.

type Job

type Job struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Users                uint32   `protobuf:"varint,2,opt,name=users,proto3" json:"users,omitempty"`
	Duration             uint32   `protobuf:"varint,3,opt,name=duration,proto3" json:"duration,omitempty"`
	Container            string   `protobuf:"bytes,4,opt,name=container,proto3" json:"container,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Job) Descriptor

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

func (*Job) GetContainer

func (m *Job) GetContainer() string

func (*Job) GetDuration

func (m *Job) GetDuration() uint32

func (*Job) GetName

func (m *Job) GetName() string

func (*Job) GetUsers

func (m *Job) GetUsers() uint32

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 Payload

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

func (*Payload) Descriptor

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

func (*Payload) GetJob

func (m *Payload) GetJob() *Job

func (*Payload) GetVersion

func (m *Payload) GetVersion() string

func (*Payload) ProtoMessage

func (*Payload) ProtoMessage()

func (*Payload) Reset

func (m *Payload) Reset()

func (*Payload) String

func (m *Payload) String() string

func (*Payload) XXX_DiscardUnknown

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal

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

func (*Payload) XXX_Merge

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

func (*Payload) XXX_Size

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal

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

type Response

type Response struct {
	Error                bool     `protobuf:"varint,1,opt,name=error,proto3" json:"error,omitempty"`
	Output               string   `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Response) Descriptor

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

func (*Response) GetError

func (m *Response) GetError() bool

func (*Response) GetOutput

func (m *Response) GetOutput() string

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) String

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal

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

func (*Response) XXX_Merge

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

func (*Response) XXX_Size

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal

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

type UnimplementedAgentServer

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentServer) Create

func (*UnimplementedAgentServer) Create(ctx context.Context, req *Payload) (*Response, error)