api

package
v0.0.0-...-858628d Latest Latest
Warning

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

 Go to latest Published: Feb 27, 2023 License: Apache-2.0, Apache-2.0 Imports: 6 Imported by: 4

Documentation

Overview

Package api is a generated protocol buffer package.

It is generated from these files: 

api.proto

It has these top-level messages: 

Recipe
RunRequest
RunResponse
Ping
Result
Pong

Index

Constants

This section is empty.

Variables

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

Functions

func RegisterRunnerServer 

func RegisterRunnerServer(s *grpc.Server, srv RunnerServer)

Types

type Ping 

type Ping struct {
}

func (*Ping) Descriptor 

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

func (*Ping) Marshal 

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

func (*Ping) MarshalTo 

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

func (*Ping) ProtoMessage 

func (*Ping) ProtoMessage()

func (*Ping) Reset 

func (m *Ping) Reset()

func (*Ping) Size 

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

func (*Ping) String 

func (m *Ping) String() string

func (*Ping) Unmarshal 

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

type Pong 

type Pong struct {
	AgentID int64 `protobuf:"varint,1,opt,name=agentID,proto3" json:"agentID,omitempty"`
}

func (*Pong) Descriptor 

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

func (*Pong) GetAgentID 

func (m *Pong) GetAgentID() int64

func (*Pong) Marshal 

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

func (*Pong) MarshalTo 

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

func (*Pong) ProtoMessage 

func (*Pong) ProtoMessage()

func (*Pong) Reset 

func (m *Pong) Reset()

func (*Pong) Size 

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

func (*Pong) String 

func (m *Pong) String() string

func (*Pong) Unmarshal 

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

type Recipe 

type Recipe struct {
	Id          int64    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Environment []string `protobuf:"bytes,3,rep,name=environment" json:"environment,omitempty"`
	Commands    string   `protobuf:"bytes,4,opt,name=commands,proto3" json:"commands,omitempty"`
}

func (*Recipe) Descriptor 

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

func (*Recipe) GetCommands 

func (m *Recipe) GetCommands() string

func (*Recipe) GetEnvironment 

func (m *Recipe) GetEnvironment() []string

func (*Recipe) GetId 

func (m *Recipe) GetId() int64

func (*Recipe) Marshal 

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

func (*Recipe) MarshalTo 

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

func (*Recipe) ProtoMessage 

func (*Recipe) ProtoMessage()

func (*Recipe) Reset 

func (m *Recipe) Reset()

func (*Recipe) Size 

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

func (*Recipe) String 

func (m *Recipe) String() string

func (*Recipe) Unmarshal 

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

type Result 

type Result struct {
	Output  string `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Success bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	AgentID int64  `protobuf:"varint,3,opt,name=agentID,proto3" json:"agentID,omitempty"`
}

func (*Result) Descriptor 

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

func (*Result) GetAgentID 

func (m *Result) GetAgentID() int64

func (*Result) GetOutput 

func (m *Result) GetOutput() string

func (*Result) GetSuccess 

func (m *Result) GetSuccess() bool

func (*Result) Marshal 

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

func (*Result) MarshalTo 

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

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) Reset 

func (m *Result) Reset()

func (*Result) Size 

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

func (*Result) String 

func (m *Result) String() string

func (*Result) Unmarshal 

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

type RunRequest 

type RunRequest struct {
	// Types that are valid to be assigned to Action:
	//	*RunRequest_Recipe
	//	*RunRequest_Ping
	Action isRunRequest_Action `protobuf_oneof:"action"`
}

func (*RunRequest) Descriptor 

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

func (*RunRequest) GetAction 

func (m *RunRequest) GetAction() isRunRequest_Action

func (*RunRequest) GetPing 

func (m *RunRequest) GetPing() *Ping

func (*RunRequest) GetRecipe 

func (m *RunRequest) GetRecipe() *Recipe

func (*RunRequest) Marshal 

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

func (*RunRequest) MarshalTo 

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

func (*RunRequest) ProtoMessage 

func (*RunRequest) ProtoMessage()

func (*RunRequest) Reset 

func (m *RunRequest) Reset()

func (*RunRequest) Size 

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

func (*RunRequest) String 

func (m *RunRequest) String() string

func (*RunRequest) Unmarshal 

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

func (*RunRequest) XXX_OneofFuncs 

func (*RunRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type RunRequest_Ping 

type RunRequest_Ping struct {
	Ping *Ping `protobuf:"bytes,2,opt,name=ping,oneof"`
}

func (*RunRequest_Ping) MarshalTo 

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

func (*RunRequest_Ping) Size 

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

type RunRequest_Recipe 

type RunRequest_Recipe struct {
	Recipe *Recipe `protobuf:"bytes,1,opt,name=recipe,oneof"`
}

func (*RunRequest_Recipe) MarshalTo 

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

func (*RunRequest_Recipe) Size 

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

type RunResponse 

type RunResponse struct {
	// Types that are valid to be assigned to Response:
	//	*RunResponse_Result
	//	*RunResponse_Pong
	Response isRunResponse_Response `protobuf_oneof:"response"`
}

func (*RunResponse) Descriptor 

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

func (*RunResponse) GetPong 

func (m *RunResponse) GetPong() *Pong

func (*RunResponse) GetResponse 

func (m *RunResponse) GetResponse() isRunResponse_Response

func (*RunResponse) GetResult 

func (m *RunResponse) GetResult() *Result

func (*RunResponse) Marshal 

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

func (*RunResponse) MarshalTo 

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

func (*RunResponse) ProtoMessage 

func (*RunResponse) ProtoMessage()

func (*RunResponse) Reset 

func (m *RunResponse) Reset()

func (*RunResponse) Size 

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

func (*RunResponse) String 

func (m *RunResponse) String() string

func (*RunResponse) Unmarshal 

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

func (*RunResponse) XXX_OneofFuncs 

func (*RunResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type RunResponse_Pong 

type RunResponse_Pong struct {
	Pong *Pong `protobuf:"bytes,2,opt,name=pong,oneof"`
}

func (*RunResponse_Pong) MarshalTo 

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

func (*RunResponse_Pong) Size 

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

type RunResponse_Result 

type RunResponse_Result struct {
	Result *Result `protobuf:"bytes,1,opt,name=result,oneof"`
}

func (*RunResponse_Result) MarshalTo 

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

func (*RunResponse_Result) Size 

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

type RunnerClient 

type RunnerClient interface {
	Run(ctx context.Context, opts ...grpc.CallOption) (Runner_RunClient, error)
}

func NewRunnerClient 

func NewRunnerClient(cc *grpc.ClientConn) RunnerClient

type RunnerServer 

type RunnerServer interface {
	Run(Runner_RunServer) error
}

type Runner_RunClient 

type Runner_RunClient interface {
	Send(*RunResponse) error
	Recv() (*RunRequest, error)
	grpc.ClientStream
}

type Runner_RunServer 

type Runner_RunServer interface {
	Send(*RunRequest) error
	Recv() (*RunResponse, error)
	grpc.ServerStream
}

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.
JackTT - Gopher 🇻🇳