go_micro_run

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Mar 19, 2018 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package go_micro_run is a generated protocol buffer package.

It is generated from these files: 

github.com/micro/micro/run/proto/run.proto

It has these top-level messages: 

Source
Binary
Process
FetchRequest
FetchResponse
BuildRequest
BuildResponse
ExecRequest
ExecResponse
KillRequest
KillResponse
WaitRequest
WaitResponse
RunRequest
RunResponse
StopRequest
StopResponse
StatusRequest
StatusResponse

Package go_micro_run is a generated protocol buffer package.

It is generated from these files: 

github.com/micro/micro/run/proto/run.proto

It has these top-level messages: 

Source
Binary
Process
FetchRequest
FetchResponse
BuildRequest
BuildResponse
ExecRequest
ExecResponse
KillRequest
KillResponse
WaitRequest
WaitResponse
RunRequest
RunResponse
StopRequest
StopResponse
StatusRequest
StatusResponse

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterRuntimeHandler 

func RegisterRuntimeHandler(s server.Server, hdlr RuntimeHandler, opts ...server.HandlerOption)

func RegisterServiceHandler 

func RegisterServiceHandler(s server.Server, hdlr ServiceHandler, opts ...server.HandlerOption)

Types

type Binary 

type Binary struct {
	Path   string  `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"`
	Source *Source `protobuf:"bytes,2,opt,name=source" json:"source,omitempty"`
}

func (*Binary) Descriptor 

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

func (*Binary) GetPath 

func (m *Binary) GetPath() string

func (*Binary) GetSource 

func (m *Binary) GetSource() *Source

func (*Binary) ProtoMessage 

func (*Binary) ProtoMessage()

func (*Binary) Reset 

func (m *Binary) Reset()

func (*Binary) String 

func (m *Binary) String() string

type BuildRequest 

type BuildRequest struct {
	Source *Source `protobuf:"bytes,1,opt,name=source" json:"source,omitempty"`
}

func (*BuildRequest) Descriptor 

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

func (*BuildRequest) GetSource 

func (m *BuildRequest) GetSource() *Source

func (*BuildRequest) ProtoMessage 

func (*BuildRequest) ProtoMessage()

func (*BuildRequest) Reset 

func (m *BuildRequest) Reset()

func (*BuildRequest) String 

func (m *BuildRequest) String() string

type BuildResponse 

type BuildResponse struct {
	Binary *Binary `protobuf:"bytes,1,opt,name=binary" json:"binary,omitempty"`
}

func (*BuildResponse) Descriptor 

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

func (*BuildResponse) GetBinary 

func (m *BuildResponse) GetBinary() *Binary

func (*BuildResponse) ProtoMessage 

func (*BuildResponse) ProtoMessage()

func (*BuildResponse) Reset 

func (m *BuildResponse) Reset()

func (*BuildResponse) String 

func (m *BuildResponse) String() string

type ExecRequest 

type ExecRequest struct {
	Binary *Binary `protobuf:"bytes,1,opt,name=binary" json:"binary,omitempty"`
}

func (*ExecRequest) Descriptor 

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

func (*ExecRequest) GetBinary 

func (m *ExecRequest) GetBinary() *Binary

func (*ExecRequest) ProtoMessage 

func (*ExecRequest) ProtoMessage()

func (*ExecRequest) Reset 

func (m *ExecRequest) Reset()

func (*ExecRequest) String 

func (m *ExecRequest) String() string

type ExecResponse 

type ExecResponse struct {
	Process *Process `protobuf:"bytes,1,opt,name=process" json:"process,omitempty"`
}

func (*ExecResponse) Descriptor 

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

func (*ExecResponse) GetProcess 

func (m *ExecResponse) GetProcess() *Process

func (*ExecResponse) ProtoMessage 

func (*ExecResponse) ProtoMessage()

func (*ExecResponse) Reset 

func (m *ExecResponse) Reset()

func (*ExecResponse) String 

func (m *ExecResponse) String() string

type FetchRequest 

type FetchRequest struct {
	Url    string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
	Update bool   `protobuf:"varint,2,opt,name=update" json:"update,omitempty"`
}

func (*FetchRequest) Descriptor 

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

func (*FetchRequest) GetUpdate 

func (m *FetchRequest) GetUpdate() bool

func (*FetchRequest) GetUrl 

func (m *FetchRequest) GetUrl() string

func (*FetchRequest) ProtoMessage 

func (*FetchRequest) ProtoMessage()

func (*FetchRequest) Reset 

func (m *FetchRequest) Reset()

func (*FetchRequest) String 

func (m *FetchRequest) String() string

type FetchResponse 

type FetchResponse struct {
	Source *Source `protobuf:"bytes,1,opt,name=source" json:"source,omitempty"`
}

func (*FetchResponse) Descriptor 

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

func (*FetchResponse) GetSource 

func (m *FetchResponse) GetSource() *Source

func (*FetchResponse) ProtoMessage 

func (*FetchResponse) ProtoMessage()

func (*FetchResponse) Reset 

func (m *FetchResponse) Reset()

func (*FetchResponse) String 

func (m *FetchResponse) String() string

type KillRequest 

type KillRequest struct {
	Process *Process `protobuf:"bytes,1,opt,name=process" json:"process,omitempty"`
}

func (*KillRequest) Descriptor 

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

func (*KillRequest) GetProcess 

func (m *KillRequest) GetProcess() *Process

func (*KillRequest) ProtoMessage 

func (*KillRequest) ProtoMessage()

func (*KillRequest) Reset 

func (m *KillRequest) Reset()

func (*KillRequest) String 

func (m *KillRequest) String() string

type KillResponse 

type KillResponse struct {
}

func (*KillResponse) Descriptor 

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

func (*KillResponse) ProtoMessage 

func (*KillResponse) ProtoMessage()

func (*KillResponse) Reset 

func (m *KillResponse) Reset()

func (*KillResponse) String 

func (m *KillResponse) String() string

type Process 

type Process struct {
	Id     string  `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Binary *Binary `protobuf:"bytes,2,opt,name=binary" json:"binary,omitempty"`
}

func (*Process) Descriptor 

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

func (*Process) GetBinary 

func (m *Process) GetBinary() *Binary

func (*Process) GetId 

func (m *Process) GetId() string

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) Reset 

func (m *Process) Reset()

func (*Process) String 

func (m *Process) String() string

type RunRequest 

type RunRequest struct {
	Url     string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
	Restart bool   `protobuf:"varint,2,opt,name=restart" json:"restart,omitempty"`
	Update  bool   `protobuf:"varint,3,opt,name=update" json:"update,omitempty"`
}

func (*RunRequest) Descriptor 

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

func (*RunRequest) GetRestart 

func (m *RunRequest) GetRestart() bool

func (*RunRequest) GetUpdate 

func (m *RunRequest) GetUpdate() bool

func (*RunRequest) GetUrl 

func (m *RunRequest) GetUrl() string

func (*RunRequest) ProtoMessage 

func (*RunRequest) ProtoMessage()

func (*RunRequest) Reset 

func (m *RunRequest) Reset()

func (*RunRequest) String 

func (m *RunRequest) String() string

type RunResponse 

type RunResponse struct {
}

func (*RunResponse) Descriptor 

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

func (*RunResponse) ProtoMessage 

func (*RunResponse) ProtoMessage()

func (*RunResponse) Reset 

func (m *RunResponse) Reset()

func (*RunResponse) String 

func (m *RunResponse) String() string

type Runtime 

type Runtime struct {
	RuntimeHandler
}

func (*Runtime) Build 

func (h *Runtime) Build(ctx context.Context, in *BuildRequest, out *BuildResponse) error

func (*Runtime) Exec 

func (h *Runtime) Exec(ctx context.Context, in *ExecRequest, out *ExecResponse) error

func (*Runtime) Fetch 

func (h *Runtime) Fetch(ctx context.Context, in *FetchRequest, out *FetchResponse) error

func (*Runtime) Kill 

func (h *Runtime) Kill(ctx context.Context, in *KillRequest, out *KillResponse) error

func (*Runtime) Wait 

func (h *Runtime) Wait(ctx context.Context, stream server.Streamer) error

type RuntimeClient 

type RuntimeClient interface {
	Fetch(ctx context.Context, in *FetchRequest, opts ...client.CallOption) (*FetchResponse, error)
	Build(ctx context.Context, in *BuildRequest, opts ...client.CallOption) (*BuildResponse, error)
	Exec(ctx context.Context, in *ExecRequest, opts ...client.CallOption) (*ExecResponse, error)
	Kill(ctx context.Context, in *KillRequest, opts ...client.CallOption) (*KillResponse, error)
	Wait(ctx context.Context, in *WaitRequest, opts ...client.CallOption) (Runtime_WaitClient, error)
}

func NewRuntimeClient 

func NewRuntimeClient(serviceName string, c client.Client) RuntimeClient

type RuntimeHandler 

type RuntimeHandler interface {
	Fetch(context.Context, *FetchRequest, *FetchResponse) error
	Build(context.Context, *BuildRequest, *BuildResponse) error
	Exec(context.Context, *ExecRequest, *ExecResponse) error
	Kill(context.Context, *KillRequest, *KillResponse) error
	Wait(context.Context, *WaitRequest, Runtime_WaitStream) error
}

type Runtime_WaitClient 

type Runtime_WaitClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*WaitResponse, error)
}

type Runtime_WaitStream 

type Runtime_WaitStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*WaitResponse) error
}

type Service 

type Service struct {
	ServiceHandler
}

func (*Service) Run 

func (h *Service) Run(ctx context.Context, in *RunRequest, out *RunResponse) error

func (*Service) Status 

func (h *Service) Status(ctx context.Context, in *StatusRequest, out *StatusResponse) error

func (*Service) Stop 

func (h *Service) Stop(ctx context.Context, in *StopRequest, out *StopResponse) error

type ServiceClient 

type ServiceClient interface {
	Run(ctx context.Context, in *RunRequest, opts ...client.CallOption) (*RunResponse, error)
	Stop(ctx context.Context, in *StopRequest, opts ...client.CallOption) (*StopResponse, error)
	Status(ctx context.Context, in *StatusRequest, opts ...client.CallOption) (*StatusResponse, error)
}

func NewServiceClient 

func NewServiceClient(serviceName string, c client.Client) ServiceClient

type ServiceHandler 

type ServiceHandler interface {
	Run(context.Context, *RunRequest, *RunResponse) error
	Stop(context.Context, *StopRequest, *StopResponse) error
	Status(context.Context, *StatusRequest, *StatusResponse) error
}

type Source 

type Source struct {
	Url string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
	Dir string `protobuf:"bytes,2,opt,name=dir" json:"dir,omitempty"`
}

func (*Source) Descriptor 

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

func (*Source) GetDir 

func (m *Source) GetDir() string

func (*Source) GetUrl 

func (m *Source) GetUrl() string

func (*Source) ProtoMessage 

func (*Source) ProtoMessage()

func (*Source) Reset 

func (m *Source) Reset()

func (*Source) String 

func (m *Source) String() string

type StatusRequest 

type StatusRequest struct {
	Url string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
}

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) GetUrl 

func (m *StatusRequest) GetUrl() string

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) String 

func (m *StatusRequest) String() string

type StatusResponse 

type StatusResponse struct {
	Info string `protobuf:"bytes,1,opt,name=info" json:"info,omitempty"`
}

func (*StatusResponse) Descriptor 

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

func (*StatusResponse) GetInfo 

func (m *StatusResponse) GetInfo() string

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset 

func (m *StatusResponse) Reset()

func (*StatusResponse) String 

func (m *StatusResponse) String() string

type StopRequest 

type StopRequest struct {
	Url string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
}

func (*StopRequest) Descriptor 

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

func (*StopRequest) GetUrl 

func (m *StopRequest) GetUrl() string

func (*StopRequest) ProtoMessage 

func (*StopRequest) ProtoMessage()

func (*StopRequest) Reset 

func (m *StopRequest) Reset()

func (*StopRequest) String 

func (m *StopRequest) String() string

type StopResponse 

type StopResponse struct {
}

func (*StopResponse) Descriptor 

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

func (*StopResponse) ProtoMessage 

func (*StopResponse) ProtoMessage()

func (*StopResponse) Reset 

func (m *StopResponse) Reset()

func (*StopResponse) String 

func (m *StopResponse) String() string

type WaitRequest 

type WaitRequest struct {
	Process *Process `protobuf:"bytes,1,opt,name=process" json:"process,omitempty"`
}

func (*WaitRequest) Descriptor 

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

func (*WaitRequest) GetProcess 

func (m *WaitRequest) GetProcess() *Process

func (*WaitRequest) ProtoMessage 

func (*WaitRequest) ProtoMessage()

func (*WaitRequest) Reset 

func (m *WaitRequest) Reset()

func (*WaitRequest) String 

func (m *WaitRequest) String() string

type WaitResponse 

type WaitResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*WaitResponse) Descriptor 

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

func (*WaitResponse) GetError 

func (m *WaitResponse) GetError() string

func (*WaitResponse) ProtoMessage 

func (*WaitResponse) ProtoMessage()

func (*WaitResponse) Reset 

func (m *WaitResponse) Reset()

func (*WaitResponse) String 

func (m *WaitResponse) String() string

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.