proto

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Nov 1, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Agent_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "eleven.agent.Agent",
	HandlerType: (*AgentServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "InitInstance",
			Handler:       _Agent_InitInstance_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "InstallRuntimes",
			Handler:       _Agent_InstallRuntimes_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "CheckDomainReachability",
			Handler:       _Agent_CheckDomainReachability_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ReconcileServedPortsState",
			Handler:       _Agent_ReconcileServedPortsState_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "TryToStartLongRunningProcess",
			Handler:       _Agent_TryToStartLongRunningProcess_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "agent.proto",
}

Agent_ServiceDesc is the grpc.ServiceDesc for Agent service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_agent_proto protoreflect.FileDescriptor

Functions

func RegisterAgentServer 

func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)

Types

type AgentClient 

type AgentClient interface {
	InitInstance(ctx context.Context, in *InitInstanceRequest, opts ...grpc.CallOption) (Agent_InitInstanceClient, error)
	InstallRuntimes(ctx context.Context, in *InstallRuntimesRequest, opts ...grpc.CallOption) (Agent_InstallRuntimesClient, error)
	CheckDomainReachability(ctx context.Context, in *CheckDomainReachabilityRequest, opts ...grpc.CallOption) (Agent_CheckDomainReachabilityClient, error)
	ReconcileServedPortsState(ctx context.Context, in *ReconcileServedPortsStateRequest, opts ...grpc.CallOption) (Agent_ReconcileServedPortsStateClient, error)
	TryToStartLongRunningProcess(ctx context.Context, in *TryToStartLongRunningProcessRequest, opts ...grpc.CallOption) (Agent_TryToStartLongRunningProcessClient, error)
}

AgentClient is the client API for Agent service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAgentClient 

func NewAgentClient(cc grpc.ClientConnInterface) AgentClient

type AgentServer 

type AgentServer interface {
	InitInstance(*InitInstanceRequest, Agent_InitInstanceServer) error
	InstallRuntimes(*InstallRuntimesRequest, Agent_InstallRuntimesServer) error
	CheckDomainReachability(*CheckDomainReachabilityRequest, Agent_CheckDomainReachabilityServer) error
	ReconcileServedPortsState(*ReconcileServedPortsStateRequest, Agent_ReconcileServedPortsStateServer) error
	TryToStartLongRunningProcess(*TryToStartLongRunningProcessRequest, Agent_TryToStartLongRunningProcessServer) error
	// contains filtered or unexported methods
}

AgentServer is the server API for Agent service. All implementations must embed UnimplementedAgentServer for forward compatibility

type Agent_CheckDomainReachabilityClient 

type Agent_CheckDomainReachabilityClient interface {
	Recv() (*CheckDomainReachabilityReply, error)
	grpc.ClientStream
}

type Agent_CheckDomainReachabilityServer 

type Agent_CheckDomainReachabilityServer interface {
	Send(*CheckDomainReachabilityReply) error
	grpc.ServerStream
}

type Agent_InitInstanceClient 

type Agent_InitInstanceClient interface {
	Recv() (*InitInstanceReply, error)
	grpc.ClientStream
}

type Agent_InitInstanceServer 

type Agent_InitInstanceServer interface {
	Send(*InitInstanceReply) error
	grpc.ServerStream
}

type Agent_InstallRuntimesClient 

type Agent_InstallRuntimesClient interface {
	Recv() (*InstallRuntimesReply, error)
	grpc.ClientStream
}

type Agent_InstallRuntimesServer 

type Agent_InstallRuntimesServer interface {
	Send(*InstallRuntimesReply) error
	grpc.ServerStream
}

type Agent_ReconcileServedPortsStateClient 

type Agent_ReconcileServedPortsStateClient interface {
	Recv() (*ReconcileServedPortsStateReply, error)
	grpc.ClientStream
}

type Agent_ReconcileServedPortsStateServer 

type Agent_ReconcileServedPortsStateServer interface {
	Send(*ReconcileServedPortsStateReply) error
	grpc.ServerStream
}

type Agent_TryToStartLongRunningProcessClient 

type Agent_TryToStartLongRunningProcessClient interface {
	Recv() (*TryToStartLongRunningProcessReply, error)
	grpc.ClientStream
}

type Agent_TryToStartLongRunningProcessServer 

type Agent_TryToStartLongRunningProcessServer interface {
	Send(*TryToStartLongRunningProcessReply) error
	grpc.ServerStream
}

type CheckDomainReachabilityReply 

type CheckDomainReachabilityReply struct {
	// contains filtered or unexported fields
}

func (*CheckDomainReachabilityReply) Descriptor deprecated 

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

Deprecated: Use CheckDomainReachabilityReply.ProtoReflect.Descriptor instead.

func (*CheckDomainReachabilityReply) ProtoMessage 

func (*CheckDomainReachabilityReply) ProtoMessage()

func (*CheckDomainReachabilityReply) ProtoReflect 

func (x *CheckDomainReachabilityReply) ProtoReflect() protoreflect.Message

func (*CheckDomainReachabilityReply) Reset 

func (x *CheckDomainReachabilityReply) Reset()

func (*CheckDomainReachabilityReply) String 

func (x *CheckDomainReachabilityReply) String() string

type CheckDomainReachabilityRequest 

type CheckDomainReachabilityRequest struct {
	Domain      string                            `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	ServedPorts map[string]*EnvServedPortBindings `` /* 182-byte string literal not displayed */
	UniqueId    string                            `protobuf:"bytes,3,opt,name=unique_id,json=uniqueId,proto3" json:"unique_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckDomainReachabilityRequest) Descriptor deprecated 

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

Deprecated: Use CheckDomainReachabilityRequest.ProtoReflect.Descriptor instead.

func (*CheckDomainReachabilityRequest) GetDomain 

func (x *CheckDomainReachabilityRequest) GetDomain() string

func (*CheckDomainReachabilityRequest) GetServedPorts 

func (x *CheckDomainReachabilityRequest) GetServedPorts() map[string]*EnvServedPortBindings

func (*CheckDomainReachabilityRequest) GetUniqueId 

func (x *CheckDomainReachabilityRequest) GetUniqueId() string

func (*CheckDomainReachabilityRequest) ProtoMessage 

func (*CheckDomainReachabilityRequest) ProtoMessage()

func (*CheckDomainReachabilityRequest) ProtoReflect 

func (x *CheckDomainReachabilityRequest) ProtoReflect() protoreflect.Message

func (*CheckDomainReachabilityRequest) Reset 

func (x *CheckDomainReachabilityRequest) Reset()

func (*CheckDomainReachabilityRequest) String 

func (x *CheckDomainReachabilityRequest) String() string

type EnvRepository 

type EnvRepository struct {
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Name  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvRepository) Descriptor deprecated 

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

Deprecated: Use EnvRepository.ProtoReflect.Descriptor instead.

func (*EnvRepository) GetName 

func (x *EnvRepository) GetName() string

func (*EnvRepository) GetOwner 

func (x *EnvRepository) GetOwner() string

func (*EnvRepository) ProtoMessage 

func (*EnvRepository) ProtoMessage()

func (*EnvRepository) ProtoReflect 

func (x *EnvRepository) ProtoReflect() protoreflect.Message

func (*EnvRepository) Reset 

func (x *EnvRepository) Reset()

func (*EnvRepository) String 

func (x *EnvRepository) String() string

type EnvServedPortBinding 

type EnvServedPortBinding struct {
	Value           string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Type            string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	RedirectToHttps bool   `protobuf:"varint,3,opt,name=redirect_to_https,json=redirectToHttps,proto3" json:"redirect_to_https,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvServedPortBinding) Descriptor deprecated 

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

Deprecated: Use EnvServedPortBinding.ProtoReflect.Descriptor instead.

func (*EnvServedPortBinding) GetRedirectToHttps 

func (x *EnvServedPortBinding) GetRedirectToHttps() bool

func (*EnvServedPortBinding) GetType 

func (x *EnvServedPortBinding) GetType() string

func (*EnvServedPortBinding) GetValue 

func (x *EnvServedPortBinding) GetValue() string

func (*EnvServedPortBinding) ProtoMessage 

func (*EnvServedPortBinding) ProtoMessage()

func (*EnvServedPortBinding) ProtoReflect 

func (x *EnvServedPortBinding) ProtoReflect() protoreflect.Message

func (*EnvServedPortBinding) Reset 

func (x *EnvServedPortBinding) Reset()

func (*EnvServedPortBinding) String 

func (x *EnvServedPortBinding) String() string

type EnvServedPortBindings 

type EnvServedPortBindings struct {
	Bindings []*EnvServedPortBinding `protobuf:"bytes,1,rep,name=bindings,proto3" json:"bindings,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvServedPortBindings) Descriptor deprecated 

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

Deprecated: Use EnvServedPortBindings.ProtoReflect.Descriptor instead.

func (*EnvServedPortBindings) GetBindings 

func (x *EnvServedPortBindings) GetBindings() []*EnvServedPortBinding

func (*EnvServedPortBindings) ProtoMessage 

func (*EnvServedPortBindings) ProtoMessage()

func (*EnvServedPortBindings) ProtoReflect 

func (x *EnvServedPortBindings) ProtoReflect() protoreflect.Message

func (*EnvServedPortBindings) Reset 

func (x *EnvServedPortBindings) Reset()

func (*EnvServedPortBindings) String 

func (x *EnvServedPortBindings) String() string

type InitInstanceReply 

type InitInstanceReply struct {
	LogLineHeader             string  `protobuf:"bytes,1,opt,name=log_line_header,json=logLineHeader,proto3" json:"log_line_header,omitempty"`
	LogLine                   string  `protobuf:"bytes,2,opt,name=log_line,json=logLine,proto3" json:"log_line,omitempty"`
	GithubSshPublicKeyContent *string `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InitInstanceReply) Descriptor deprecated 

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

Deprecated: Use InitInstanceReply.ProtoReflect.Descriptor instead.

func (*InitInstanceReply) GetGithubSshPublicKeyContent 

func (x *InitInstanceReply) GetGithubSshPublicKeyContent() string

func (*InitInstanceReply) GetLogLine 

func (x *InitInstanceReply) GetLogLine() string

func (*InitInstanceReply) GetLogLineHeader 

func (x *InitInstanceReply) GetLogLineHeader() string

func (*InitInstanceReply) ProtoMessage 

func (*InitInstanceReply) ProtoMessage()

func (*InitInstanceReply) ProtoReflect 

func (x *InitInstanceReply) ProtoReflect() protoreflect.Message

func (*InitInstanceReply) Reset 

func (x *InitInstanceReply) Reset()

func (*InitInstanceReply) String 

func (x *InitInstanceReply) String() string

type InitInstanceRequest 

type InitInstanceRequest struct {
	EnvName         string           `protobuf:"bytes,1,opt,name=env_name,json=envName,proto3" json:"env_name,omitempty"`
	EnvNameSlug     string           `protobuf:"bytes,2,opt,name=env_name_slug,json=envNameSlug,proto3" json:"env_name_slug,omitempty"`
	EnvRepos        []*EnvRepository `protobuf:"bytes,3,rep,name=env_repos,json=envRepos,proto3" json:"env_repos,omitempty"`
	GithubUserEmail string           `protobuf:"bytes,4,opt,name=github_user_email,json=githubUserEmail,proto3" json:"github_user_email,omitempty"`
	UserFullName    string           `protobuf:"bytes,5,opt,name=user_full_name,json=userFullName,proto3" json:"user_full_name,omitempty"`
	// contains filtered or unexported fields
}

func (*InitInstanceRequest) Descriptor deprecated 

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

Deprecated: Use InitInstanceRequest.ProtoReflect.Descriptor instead.

func (*InitInstanceRequest) GetEnvName 

func (x *InitInstanceRequest) GetEnvName() string

func (*InitInstanceRequest) GetEnvNameSlug 

func (x *InitInstanceRequest) GetEnvNameSlug() string

func (*InitInstanceRequest) GetEnvRepos 

func (x *InitInstanceRequest) GetEnvRepos() []*EnvRepository

func (*InitInstanceRequest) GetGithubUserEmail 

func (x *InitInstanceRequest) GetGithubUserEmail() string

func (*InitInstanceRequest) GetUserFullName 

func (x *InitInstanceRequest) GetUserFullName() string

func (*InitInstanceRequest) ProtoMessage 

func (*InitInstanceRequest) ProtoMessage()

func (*InitInstanceRequest) ProtoReflect 

func (x *InitInstanceRequest) ProtoReflect() protoreflect.Message

func (*InitInstanceRequest) Reset 

func (x *InitInstanceRequest) Reset()

func (*InitInstanceRequest) String 

func (x *InitInstanceRequest) String() string

type InstallRuntimesReply 

type InstallRuntimesReply struct {
	LogLineHeader string `protobuf:"bytes,1,opt,name=log_line_header,json=logLineHeader,proto3" json:"log_line_header,omitempty"`
	LogLine       string `protobuf:"bytes,2,opt,name=log_line,json=logLine,proto3" json:"log_line,omitempty"`
	// contains filtered or unexported fields
}

func (*InstallRuntimesReply) Descriptor deprecated 

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

Deprecated: Use InstallRuntimesReply.ProtoReflect.Descriptor instead.

func (*InstallRuntimesReply) GetLogLine 

func (x *InstallRuntimesReply) GetLogLine() string

func (*InstallRuntimesReply) GetLogLineHeader 

func (x *InstallRuntimesReply) GetLogLineHeader() string

func (*InstallRuntimesReply) ProtoMessage 

func (*InstallRuntimesReply) ProtoMessage()

func (*InstallRuntimesReply) ProtoReflect 

func (x *InstallRuntimesReply) ProtoReflect() protoreflect.Message

func (*InstallRuntimesReply) Reset 

func (x *InstallRuntimesReply) Reset()

func (*InstallRuntimesReply) String 

func (x *InstallRuntimesReply) String() string

type InstallRuntimesRequest 

type InstallRuntimesRequest struct {
	Runtimes map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InstallRuntimesRequest) Descriptor deprecated 

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

Deprecated: Use InstallRuntimesRequest.ProtoReflect.Descriptor instead.

func (*InstallRuntimesRequest) GetRuntimes 

func (x *InstallRuntimesRequest) GetRuntimes() map[string]string

func (*InstallRuntimesRequest) ProtoMessage 

func (*InstallRuntimesRequest) ProtoMessage()

func (*InstallRuntimesRequest) ProtoReflect 

func (x *InstallRuntimesRequest) ProtoReflect() protoreflect.Message

func (*InstallRuntimesRequest) Reset 

func (x *InstallRuntimesRequest) Reset()

func (*InstallRuntimesRequest) String 

func (x *InstallRuntimesRequest) String() string

type ReconcileServedPortsStateReply 

type ReconcileServedPortsStateReply struct {
	// contains filtered or unexported fields
}

func (*ReconcileServedPortsStateReply) Descriptor deprecated 

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

Deprecated: Use ReconcileServedPortsStateReply.ProtoReflect.Descriptor instead.

func (*ReconcileServedPortsStateReply) ProtoMessage 

func (*ReconcileServedPortsStateReply) ProtoMessage()

func (*ReconcileServedPortsStateReply) ProtoReflect 

func (x *ReconcileServedPortsStateReply) ProtoReflect() protoreflect.Message

func (*ReconcileServedPortsStateReply) Reset 

func (x *ReconcileServedPortsStateReply) Reset()

func (*ReconcileServedPortsStateReply) String 

func (x *ReconcileServedPortsStateReply) String() string

type ReconcileServedPortsStateRequest 

type ReconcileServedPortsStateRequest struct {
	ServedPorts map[string]*EnvServedPortBindings `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ReconcileServedPortsStateRequest) Descriptor deprecated 

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

Deprecated: Use ReconcileServedPortsStateRequest.ProtoReflect.Descriptor instead.

func (*ReconcileServedPortsStateRequest) GetServedPorts 

func (x *ReconcileServedPortsStateRequest) GetServedPorts() map[string]*EnvServedPortBindings

func (*ReconcileServedPortsStateRequest) ProtoMessage 

func (*ReconcileServedPortsStateRequest) ProtoMessage()

func (*ReconcileServedPortsStateRequest) ProtoReflect 

func (x *ReconcileServedPortsStateRequest) ProtoReflect() protoreflect.Message

func (*ReconcileServedPortsStateRequest) Reset 

func (x *ReconcileServedPortsStateRequest) Reset()

func (*ReconcileServedPortsStateRequest) String 

func (x *ReconcileServedPortsStateRequest) String() string

type TryToStartLongRunningProcessReply 

type TryToStartLongRunningProcessReply struct {
	Heartbeat    string `protobuf:"bytes,1,opt,name=heartbeat,proto3" json:"heartbeat,omitempty"`
	ErrorOutput  string `protobuf:"bytes,2,opt,name=error_output,json=errorOutput,proto3" json:"error_output,omitempty"`
	ErrorMessage string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

func (*TryToStartLongRunningProcessReply) Descriptor deprecated 

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

Deprecated: Use TryToStartLongRunningProcessReply.ProtoReflect.Descriptor instead.

func (*TryToStartLongRunningProcessReply) GetErrorMessage 

func (x *TryToStartLongRunningProcessReply) GetErrorMessage() string

func (*TryToStartLongRunningProcessReply) GetErrorOutput 

func (x *TryToStartLongRunningProcessReply) GetErrorOutput() string

func (*TryToStartLongRunningProcessReply) GetHeartbeat 

func (x *TryToStartLongRunningProcessReply) GetHeartbeat() string

func (*TryToStartLongRunningProcessReply) ProtoMessage 

func (*TryToStartLongRunningProcessReply) ProtoMessage()

func (*TryToStartLongRunningProcessReply) ProtoReflect 

func (x *TryToStartLongRunningProcessReply) ProtoReflect() protoreflect.Message

func (*TryToStartLongRunningProcessReply) Reset 

func (x *TryToStartLongRunningProcessReply) Reset()

func (*TryToStartLongRunningProcessReply) String 

func (x *TryToStartLongRunningProcessReply) String() string

type TryToStartLongRunningProcessRequest 

type TryToStartLongRunningProcessRequest struct {
	Cwd string `protobuf:"bytes,1,opt,name=cwd,proto3" json:"cwd,omitempty"`
	Cmd string `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"`
	// contains filtered or unexported fields
}

func (*TryToStartLongRunningProcessRequest) Descriptor deprecated 

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

Deprecated: Use TryToStartLongRunningProcessRequest.ProtoReflect.Descriptor instead.

func (*TryToStartLongRunningProcessRequest) GetCmd 

func (x *TryToStartLongRunningProcessRequest) GetCmd() string

func (*TryToStartLongRunningProcessRequest) GetCwd 

func (x *TryToStartLongRunningProcessRequest) GetCwd() string

func (*TryToStartLongRunningProcessRequest) ProtoMessage 

func (*TryToStartLongRunningProcessRequest) ProtoMessage()

func (*TryToStartLongRunningProcessRequest) ProtoReflect 

func (x *TryToStartLongRunningProcessRequest) ProtoReflect() protoreflect.Message

func (*TryToStartLongRunningProcessRequest) Reset 

func (x *TryToStartLongRunningProcessRequest) Reset()

func (*TryToStartLongRunningProcessRequest) String 

func (x *TryToStartLongRunningProcessRequest) String() string

type UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentServer) CheckDomainReachability 

func (UnimplementedAgentServer) CheckDomainReachability(*CheckDomainReachabilityRequest, Agent_CheckDomainReachabilityServer) error

func (UnimplementedAgentServer) InitInstance 

func (UnimplementedAgentServer) InitInstance(*InitInstanceRequest, Agent_InitInstanceServer) error

func (UnimplementedAgentServer) InstallRuntimes 

func (UnimplementedAgentServer) InstallRuntimes(*InstallRuntimesRequest, Agent_InstallRuntimesServer) error

func (UnimplementedAgentServer) ReconcileServedPortsState 

func (UnimplementedAgentServer) ReconcileServedPortsState(*ReconcileServedPortsStateRequest, Agent_ReconcileServedPortsStateServer) error

func (UnimplementedAgentServer) TryToStartLongRunningProcess 

func (UnimplementedAgentServer) TryToStartLongRunningProcess(*TryToStartLongRunningProcessRequest, Agent_TryToStartLongRunningProcessServer) error

type UnsafeAgentServer 

type UnsafeAgentServer interface {
	// contains filtered or unexported methods
}

UnsafeAgentServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentServer will result in compilation errors.

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.