v0

package
v0.1.132 Latest Latest
Warning

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

 Go to latest Published: Jul 19, 2024 License: MIT Imports: 22 Imported by: 0

Documentation

Overview

Package v0 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	CLI_Ping_FullMethodName                                     = "/codefly.cli.v0.CLI/Ping"
	CLI_GetAgentInformation_FullMethodName                      = "/codefly.cli.v0.CLI/GetAgentInformation"
	CLI_GetWorkspaceInventory_FullMethodName                    = "/codefly.cli.v0.CLI/GetWorkspaceInventory"
	CLI_GetWorkspaceServiceDependencyGraph_FullMethodName       = "/codefly.cli.v0.CLI/GetWorkspaceServiceDependencyGraph"
	CLI_GetWorkspacePublicModulesDependencyGraph_FullMethodName = "/codefly.cli.v0.CLI/GetWorkspacePublicModulesDependencyGraph"
	CLI_GetActive_FullMethodName                                = "/codefly.cli.v0.CLI/GetActive"
	CLI_GetAddresses_FullMethodName                             = "/codefly.cli.v0.CLI/GetAddresses"
	CLI_GetConfiguration_FullMethodName                         = "/codefly.cli.v0.CLI/GetConfiguration"
	CLI_GetDependenciesConfigurations_FullMethodName            = "/codefly.cli.v0.CLI/GetDependenciesConfigurations"
	CLI_GetDependenciesNetworkMappings_FullMethodName           = "/codefly.cli.v0.CLI/GetDependenciesNetworkMappings"
	CLI_GetRuntimeConfigurations_FullMethodName                 = "/codefly.cli.v0.CLI/GetRuntimeConfigurations"
	CLI_Logs_FullMethodName                                     = "/codefly.cli.v0.CLI/Logs"
	CLI_ActiveLogHistory_FullMethodName                         = "/codefly.cli.v0.CLI/ActiveLogHistory"
	CLI_GetFlowStatus_FullMethodName                            = "/codefly.cli.v0.CLI/GetFlowStatus"
	CLI_StopFlow_FullMethodName                                 = "/codefly.cli.v0.CLI/StopFlow"
	CLI_DestroyFlow_FullMethodName                              = "/codefly.cli.v0.CLI/DestroyFlow"
)

Variables

View Source 
var CLI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "codefly.cli.v0.CLI",
	HandlerType: (*CLIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _CLI_Ping_Handler,
		},
		{
			MethodName: "GetAgentInformation",
			Handler:    _CLI_GetAgentInformation_Handler,
		},
		{
			MethodName: "GetWorkspaceInventory",
			Handler:    _CLI_GetWorkspaceInventory_Handler,
		},
		{
			MethodName: "GetWorkspaceServiceDependencyGraph",
			Handler:    _CLI_GetWorkspaceServiceDependencyGraph_Handler,
		},
		{
			MethodName: "GetWorkspacePublicModulesDependencyGraph",
			Handler:    _CLI_GetWorkspacePublicModulesDependencyGraph_Handler,
		},
		{
			MethodName: "GetActive",
			Handler:    _CLI_GetActive_Handler,
		},
		{
			MethodName: "GetAddresses",
			Handler:    _CLI_GetAddresses_Handler,
		},
		{
			MethodName: "GetConfiguration",
			Handler:    _CLI_GetConfiguration_Handler,
		},
		{
			MethodName: "GetDependenciesConfigurations",
			Handler:    _CLI_GetDependenciesConfigurations_Handler,
		},
		{
			MethodName: "GetDependenciesNetworkMappings",
			Handler:    _CLI_GetDependenciesNetworkMappings_Handler,
		},
		{
			MethodName: "GetRuntimeConfigurations",
			Handler:    _CLI_GetRuntimeConfigurations_Handler,
		},
		{
			MethodName: "ActiveLogHistory",
			Handler:    _CLI_ActiveLogHistory_Handler,
		},
		{
			MethodName: "GetFlowStatus",
			Handler:    _CLI_GetFlowStatus_Handler,
		},
		{
			MethodName: "StopFlow",
			Handler:    _CLI_StopFlow_Handler,
		},
		{
			MethodName: "DestroyFlow",
			Handler:    _CLI_DestroyFlow_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Logs",
			Handler:       _CLI_Logs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "codefly/cli/v0/cli.proto",
}

CLI_ServiceDesc is the grpc.ServiceDesc for CLI 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_codefly_cli_v0_cli_proto protoreflect.FileDescriptor
View Source 
var File_codefly_cli_v0_utils_proto protoreflect.FileDescriptor

Functions

func RegisterCLIHandler 

func RegisterCLIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterCLIHandler registers the http handlers for service CLI to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterCLIHandlerClient 

func RegisterCLIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client CLIClient) error

RegisterCLIHandlerClient registers the http handlers for service CLI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "CLIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "CLIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "CLIClient" to call the correct interceptors.

func RegisterCLIHandlerFromEndpoint 

func RegisterCLIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterCLIHandlerFromEndpoint is same as RegisterCLIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterCLIHandlerServer 

func RegisterCLIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server CLIServer) error

RegisterCLIHandlerServer registers the http handlers for service CLI to "mux". UnaryRPC :call CLIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterCLIHandlerFromEndpoint instead.

func RegisterCLIServer 

func RegisterCLIServer(s grpc.ServiceRegistrar, srv CLIServer)

Types

type ActiveResponse 

type ActiveResponse struct {
	Workspace string `protobuf:"bytes,1,opt,name=workspace,proto3" json:"workspace,omitempty"`
	Module    string `protobuf:"bytes,2,opt,name=module,proto3" json:"module,omitempty"`
	Service   string `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*ActiveResponse) Descriptor deprecated 

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

Deprecated: Use ActiveResponse.ProtoReflect.Descriptor instead.

func (*ActiveResponse) GetModule 

func (x *ActiveResponse) GetModule() string

func (*ActiveResponse) GetService 

func (x *ActiveResponse) GetService() string

func (*ActiveResponse) GetWorkspace 

func (x *ActiveResponse) GetWorkspace() string

func (*ActiveResponse) ProtoMessage 

func (*ActiveResponse) ProtoMessage()

func (*ActiveResponse) ProtoReflect 

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

func (*ActiveResponse) Reset 

func (x *ActiveResponse) Reset()

func (*ActiveResponse) String 

func (x *ActiveResponse) String() string

type CLIClient 

type CLIClient interface {
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetAgentInformation(ctx context.Context, in *GetAgentInformationRequest, opts ...grpc.CallOption) (*v0.AgentInformation, error)
	GetWorkspaceInventory(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*v01.Workspace, error)
	GetWorkspaceServiceDependencyGraph(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*v02.GraphResponse, error)
	GetWorkspacePublicModulesDependencyGraph(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MultiGraphResponse, error)
	GetActive(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ActiveResponse, error)
	GetAddresses(ctx context.Context, in *GetAddressRequest, opts ...grpc.CallOption) (*GetAddressResponse, error)
	GetConfiguration(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*GetConfigurationResponse, error)
	GetDependenciesConfigurations(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*GetConfigurationsResponse, error)
	GetDependenciesNetworkMappings(ctx context.Context, in *GetNetworkMappingsRequest, opts ...grpc.CallOption) (*GetNetworkMappingsResponse, error)
	GetRuntimeConfigurations(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*GetConfigurationsResponse, error)
	Logs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (CLI_LogsClient, error)
	ActiveLogHistory(ctx context.Context, in *v02.LogRequest, opts ...grpc.CallOption) (*v02.LogResponse, error)
	GetFlowStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FlowStatus, error)
	StopFlow(ctx context.Context, in *StopFlowRequest, opts ...grpc.CallOption) (*StopFlowResponse, error)
	DestroyFlow(ctx context.Context, in *DestroyFlowRequest, opts ...grpc.CallOption) (*DestroyFlowResponse, error)
}

CLIClient is the client API for CLI 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 NewCLIClient 

func NewCLIClient(cc grpc.ClientConnInterface) CLIClient

type CLIServer 

type CLIServer interface {
	Ping(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	GetAgentInformation(context.Context, *GetAgentInformationRequest) (*v0.AgentInformation, error)
	GetWorkspaceInventory(context.Context, *emptypb.Empty) (*v01.Workspace, error)
	GetWorkspaceServiceDependencyGraph(context.Context, *emptypb.Empty) (*v02.GraphResponse, error)
	GetWorkspacePublicModulesDependencyGraph(context.Context, *emptypb.Empty) (*MultiGraphResponse, error)
	GetActive(context.Context, *emptypb.Empty) (*ActiveResponse, error)
	GetAddresses(context.Context, *GetAddressRequest) (*GetAddressResponse, error)
	GetConfiguration(context.Context, *GetConfigurationRequest) (*GetConfigurationResponse, error)
	GetDependenciesConfigurations(context.Context, *GetConfigurationRequest) (*GetConfigurationsResponse, error)
	GetDependenciesNetworkMappings(context.Context, *GetNetworkMappingsRequest) (*GetNetworkMappingsResponse, error)
	GetRuntimeConfigurations(context.Context, *GetConfigurationRequest) (*GetConfigurationsResponse, error)
	Logs(*emptypb.Empty, CLI_LogsServer) error
	ActiveLogHistory(context.Context, *v02.LogRequest) (*v02.LogResponse, error)
	GetFlowStatus(context.Context, *emptypb.Empty) (*FlowStatus, error)
	StopFlow(context.Context, *StopFlowRequest) (*StopFlowResponse, error)
	DestroyFlow(context.Context, *DestroyFlowRequest) (*DestroyFlowResponse, error)
	// contains filtered or unexported methods
}

CLIServer is the server API for CLI service. All implementations must embed UnimplementedCLIServer for forward compatibility

type CLI_LogsClient 

type CLI_LogsClient interface {
	Recv() (*v02.Log, error)
	grpc.ClientStream
}

type CLI_LogsServer 

type CLI_LogsServer interface {
	Send(*v02.Log) error
	grpc.ServerStream
}

type DestroyFlowRequest 

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

func (*DestroyFlowRequest) Descriptor deprecated 

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

Deprecated: Use DestroyFlowRequest.ProtoReflect.Descriptor instead.

func (*DestroyFlowRequest) ProtoMessage 

func (*DestroyFlowRequest) ProtoMessage()

func (*DestroyFlowRequest) ProtoReflect 

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

func (*DestroyFlowRequest) Reset 

func (x *DestroyFlowRequest) Reset()

func (*DestroyFlowRequest) String 

func (x *DestroyFlowRequest) String() string

type DestroyFlowResponse 

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

func (*DestroyFlowResponse) Descriptor deprecated 

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

Deprecated: Use DestroyFlowResponse.ProtoReflect.Descriptor instead.

func (*DestroyFlowResponse) ProtoMessage 

func (*DestroyFlowResponse) ProtoMessage()

func (*DestroyFlowResponse) ProtoReflect 

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

func (*DestroyFlowResponse) Reset 

func (x *DestroyFlowResponse) Reset()

func (*DestroyFlowResponse) String 

func (x *DestroyFlowResponse) String() string

type Directory added in v0.1.125 

type Directory struct {
	Files []*FileInfo `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

func (*Directory) Descriptor deprecated added in v0.1.125 

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

Deprecated: Use Directory.ProtoReflect.Descriptor instead.

func (*Directory) GetFiles added in v0.1.125 

func (x *Directory) GetFiles() []*FileInfo

func (*Directory) ProtoMessage added in v0.1.125 

func (*Directory) ProtoMessage()

func (*Directory) ProtoReflect added in v0.1.125 

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

func (*Directory) Reset added in v0.1.125 

func (x *Directory) Reset()

func (*Directory) String added in v0.1.125 

func (x *Directory) String() string

type FileInfo added in v0.1.124 

type FileInfo struct {
	Path        string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Content     []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	IsDirectory bool   `protobuf:"varint,3,opt,name=is_directory,json=isDirectory,proto3" json:"is_directory,omitempty"`
	// contains filtered or unexported fields
}

func (*FileInfo) Descriptor deprecated added in v0.1.124 

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

Deprecated: Use FileInfo.ProtoReflect.Descriptor instead.

func (*FileInfo) GetContent added in v0.1.124 

func (x *FileInfo) GetContent() []byte

func (*FileInfo) GetIsDirectory added in v0.1.124 

func (x *FileInfo) GetIsDirectory() bool

func (*FileInfo) GetPath added in v0.1.124 

func (x *FileInfo) GetPath() string

func (*FileInfo) ProtoMessage added in v0.1.124 

func (*FileInfo) ProtoMessage()

func (*FileInfo) ProtoReflect added in v0.1.124 

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

func (*FileInfo) Reset added in v0.1.124 

func (x *FileInfo) Reset()

func (*FileInfo) String added in v0.1.124 

func (x *FileInfo) String() string

type FlowStatus 

type FlowStatus struct {
	Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowStatus) Descriptor deprecated 

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

Deprecated: Use FlowStatus.ProtoReflect.Descriptor instead.

func (*FlowStatus) GetReady 

func (x *FlowStatus) GetReady() bool

func (*FlowStatus) ProtoMessage 

func (*FlowStatus) ProtoMessage()

func (*FlowStatus) ProtoReflect 

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

func (*FlowStatus) Reset 

func (x *FlowStatus) Reset()

func (*FlowStatus) String 

func (x *FlowStatus) String() string

type GetAddressRequest 

type GetAddressRequest struct {
	Module   string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	Service  string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Endpoint string `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAddressRequest) Descriptor deprecated 

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

Deprecated: Use GetAddressRequest.ProtoReflect.Descriptor instead.

func (*GetAddressRequest) GetEndpoint 

func (x *GetAddressRequest) GetEndpoint() string

func (*GetAddressRequest) GetModule 

func (x *GetAddressRequest) GetModule() string

func (*GetAddressRequest) GetService 

func (x *GetAddressRequest) GetService() string

func (*GetAddressRequest) ProtoMessage 

func (*GetAddressRequest) ProtoMessage()

func (*GetAddressRequest) ProtoReflect 

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

func (*GetAddressRequest) Reset 

func (x *GetAddressRequest) Reset()

func (*GetAddressRequest) String 

func (x *GetAddressRequest) String() string

type GetAddressResponse 

type GetAddressResponse struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAddressResponse) Descriptor deprecated 

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

Deprecated: Use GetAddressResponse.ProtoReflect.Descriptor instead.

func (*GetAddressResponse) GetAddress 

func (x *GetAddressResponse) GetAddress() string

func (*GetAddressResponse) ProtoMessage 

func (*GetAddressResponse) ProtoMessage()

func (*GetAddressResponse) ProtoReflect 

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

func (*GetAddressResponse) Reset 

func (x *GetAddressResponse) Reset()

func (*GetAddressResponse) String 

func (x *GetAddressResponse) String() string

type GetAgentInformationRequest 

type GetAgentInformationRequest struct {
	Agent string `protobuf:"bytes,1,opt,name=agent,proto3" json:"agent,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAgentInformationRequest) Descriptor deprecated 

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

Deprecated: Use GetAgentInformationRequest.ProtoReflect.Descriptor instead.

func (*GetAgentInformationRequest) GetAgent 

func (x *GetAgentInformationRequest) GetAgent() string

func (*GetAgentInformationRequest) ProtoMessage 

func (*GetAgentInformationRequest) ProtoMessage()

func (*GetAgentInformationRequest) ProtoReflect 

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

func (*GetAgentInformationRequest) Reset 

func (x *GetAgentInformationRequest) Reset()

func (*GetAgentInformationRequest) String 

func (x *GetAgentInformationRequest) String() string

type GetConfigurationRequest 

type GetConfigurationRequest struct {
	Module  string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use GetConfigurationRequest.ProtoReflect.Descriptor instead.

func (*GetConfigurationRequest) GetModule 

func (x *GetConfigurationRequest) GetModule() string

func (*GetConfigurationRequest) GetService 

func (x *GetConfigurationRequest) GetService() string

func (*GetConfigurationRequest) ProtoMessage 

func (*GetConfigurationRequest) ProtoMessage()

func (*GetConfigurationRequest) ProtoReflect 

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

func (*GetConfigurationRequest) Reset 

func (x *GetConfigurationRequest) Reset()

func (*GetConfigurationRequest) String 

func (x *GetConfigurationRequest) String() string

type GetConfigurationResponse 

type GetConfigurationResponse struct {
	Configuration *v01.Configuration `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConfigurationResponse) Descriptor deprecated 

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

Deprecated: Use GetConfigurationResponse.ProtoReflect.Descriptor instead.

func (*GetConfigurationResponse) GetConfiguration 

func (x *GetConfigurationResponse) GetConfiguration() *v01.Configuration

func (*GetConfigurationResponse) ProtoMessage 

func (*GetConfigurationResponse) ProtoMessage()

func (*GetConfigurationResponse) ProtoReflect 

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

func (*GetConfigurationResponse) Reset 

func (x *GetConfigurationResponse) Reset()

func (*GetConfigurationResponse) String 

func (x *GetConfigurationResponse) String() string

type GetConfigurationsResponse 

type GetConfigurationsResponse struct {
	Configurations []*v01.Configuration `protobuf:"bytes,1,rep,name=configurations,proto3" json:"configurations,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConfigurationsResponse) Descriptor deprecated 

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

Deprecated: Use GetConfigurationsResponse.ProtoReflect.Descriptor instead.

func (*GetConfigurationsResponse) GetConfigurations 

func (x *GetConfigurationsResponse) GetConfigurations() []*v01.Configuration

func (*GetConfigurationsResponse) ProtoMessage 

func (*GetConfigurationsResponse) ProtoMessage()

func (*GetConfigurationsResponse) ProtoReflect 

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

func (*GetConfigurationsResponse) Reset 

func (x *GetConfigurationsResponse) Reset()

func (*GetConfigurationsResponse) String 

func (x *GetConfigurationsResponse) String() string

type GetNetworkMappingsRequest added in v0.1.123 

type GetNetworkMappingsRequest struct {
	Module  string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

Get Network Mappings

func (*GetNetworkMappingsRequest) Descriptor deprecated added in v0.1.123 

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

Deprecated: Use GetNetworkMappingsRequest.ProtoReflect.Descriptor instead.

func (*GetNetworkMappingsRequest) GetModule added in v0.1.123 

func (x *GetNetworkMappingsRequest) GetModule() string

func (*GetNetworkMappingsRequest) GetService added in v0.1.123 

func (x *GetNetworkMappingsRequest) GetService() string

func (*GetNetworkMappingsRequest) ProtoMessage added in v0.1.123 

func (*GetNetworkMappingsRequest) ProtoMessage()

func (*GetNetworkMappingsRequest) ProtoReflect added in v0.1.123 

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

func (*GetNetworkMappingsRequest) Reset added in v0.1.123 

func (x *GetNetworkMappingsRequest) Reset()

func (*GetNetworkMappingsRequest) String added in v0.1.123 

func (x *GetNetworkMappingsRequest) String() string

type GetNetworkMappingsResponse added in v0.1.123 

type GetNetworkMappingsResponse struct {
	NetworkMappings []*v01.NetworkMapping `protobuf:"bytes,1,rep,name=network_mappings,json=networkMappings,proto3" json:"network_mappings,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNetworkMappingsResponse) Descriptor deprecated added in v0.1.123 

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

Deprecated: Use GetNetworkMappingsResponse.ProtoReflect.Descriptor instead.

func (*GetNetworkMappingsResponse) GetNetworkMappings added in v0.1.123 

func (x *GetNetworkMappingsResponse) GetNetworkMappings() []*v01.NetworkMapping

func (*GetNetworkMappingsResponse) ProtoMessage added in v0.1.123 

func (*GetNetworkMappingsResponse) ProtoMessage()

func (*GetNetworkMappingsResponse) ProtoReflect added in v0.1.123 

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

func (*GetNetworkMappingsResponse) Reset added in v0.1.123 

func (x *GetNetworkMappingsResponse) Reset()

func (*GetNetworkMappingsResponse) String added in v0.1.123 

func (x *GetNetworkMappingsResponse) String() string

type MultiGraphResponse 

type MultiGraphResponse struct {
	Graphs []*v0.GraphResponse `protobuf:"bytes,1,rep,name=graphs,proto3" json:"graphs,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiGraphResponse) Descriptor deprecated 

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

Deprecated: Use MultiGraphResponse.ProtoReflect.Descriptor instead.

func (*MultiGraphResponse) GetGraphs 

func (x *MultiGraphResponse) GetGraphs() []*v0.GraphResponse

func (*MultiGraphResponse) ProtoMessage 

func (*MultiGraphResponse) ProtoMessage()

func (*MultiGraphResponse) ProtoReflect 

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

func (*MultiGraphResponse) Reset 

func (x *MultiGraphResponse) Reset()

func (*MultiGraphResponse) String 

func (x *MultiGraphResponse) String() string

type RunningInformation 

type RunningInformation struct {
	Module   string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	Service  string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	AgentPid int32  `protobuf:"varint,3,opt,name=agent_pid,json=agentPid,proto3" json:"agent_pid,omitempty"`
	// contains filtered or unexported fields
}

func (*RunningInformation) Descriptor deprecated 

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

Deprecated: Use RunningInformation.ProtoReflect.Descriptor instead.

func (*RunningInformation) GetAgentPid 

func (x *RunningInformation) GetAgentPid() int32

func (*RunningInformation) GetModule 

func (x *RunningInformation) GetModule() string

func (*RunningInformation) GetService 

func (x *RunningInformation) GetService() string

func (*RunningInformation) ProtoMessage 

func (*RunningInformation) ProtoMessage()

func (*RunningInformation) ProtoReflect 

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

func (*RunningInformation) Reset 

func (x *RunningInformation) Reset()

func (*RunningInformation) String 

func (x *RunningInformation) String() string

type StopFlowRequest 

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

func (*StopFlowRequest) Descriptor deprecated 

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

Deprecated: Use StopFlowRequest.ProtoReflect.Descriptor instead.

func (*StopFlowRequest) ProtoMessage 

func (*StopFlowRequest) ProtoMessage()

func (*StopFlowRequest) ProtoReflect 

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

func (*StopFlowRequest) Reset 

func (x *StopFlowRequest) Reset()

func (*StopFlowRequest) String 

func (x *StopFlowRequest) String() string

type StopFlowResponse 

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

func (*StopFlowResponse) Descriptor deprecated 

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

Deprecated: Use StopFlowResponse.ProtoReflect.Descriptor instead.

func (*StopFlowResponse) ProtoMessage 

func (*StopFlowResponse) ProtoMessage()

func (*StopFlowResponse) ProtoReflect 

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

func (*StopFlowResponse) Reset 

func (x *StopFlowResponse) Reset()

func (*StopFlowResponse) String 

func (x *StopFlowResponse) String() string

type UnimplementedCLIServer 

type UnimplementedCLIServer struct {
}

UnimplementedCLIServer must be embedded to have forward compatible implementations.

func (UnimplementedCLIServer) ActiveLogHistory 

func (UnimplementedCLIServer) ActiveLogHistory(context.Context, *v02.LogRequest) (*v02.LogResponse, error)

func (UnimplementedCLIServer) DestroyFlow 

func (UnimplementedCLIServer) DestroyFlow(context.Context, *DestroyFlowRequest) (*DestroyFlowResponse, error)

func (UnimplementedCLIServer) GetActive 

func (UnimplementedCLIServer) GetActive(context.Context, *emptypb.Empty) (*ActiveResponse, error)

func (UnimplementedCLIServer) GetAddresses 

func (UnimplementedCLIServer) GetAddresses(context.Context, *GetAddressRequest) (*GetAddressResponse, error)

func (UnimplementedCLIServer) GetAgentInformation 

func (UnimplementedCLIServer) GetAgentInformation(context.Context, *GetAgentInformationRequest) (*v0.AgentInformation, error)

func (UnimplementedCLIServer) GetConfiguration 

func (UnimplementedCLIServer) GetConfiguration(context.Context, *GetConfigurationRequest) (*GetConfigurationResponse, error)

func (UnimplementedCLIServer) GetDependenciesConfigurations 

func (UnimplementedCLIServer) GetDependenciesConfigurations(context.Context, *GetConfigurationRequest) (*GetConfigurationsResponse, error)

func (UnimplementedCLIServer) GetDependenciesNetworkMappings added in v0.1.123 

func (UnimplementedCLIServer) GetDependenciesNetworkMappings(context.Context, *GetNetworkMappingsRequest) (*GetNetworkMappingsResponse, error)

func (UnimplementedCLIServer) GetFlowStatus 

func (UnimplementedCLIServer) GetFlowStatus(context.Context, *emptypb.Empty) (*FlowStatus, error)

func (UnimplementedCLIServer) GetRuntimeConfigurations 

func (UnimplementedCLIServer) GetRuntimeConfigurations(context.Context, *GetConfigurationRequest) (*GetConfigurationsResponse, error)

func (UnimplementedCLIServer) GetWorkspaceInventory 

func (UnimplementedCLIServer) GetWorkspaceInventory(context.Context, *emptypb.Empty) (*v01.Workspace, error)

func (UnimplementedCLIServer) GetWorkspacePublicModulesDependencyGraph 

func (UnimplementedCLIServer) GetWorkspacePublicModulesDependencyGraph(context.Context, *emptypb.Empty) (*MultiGraphResponse, error)

func (UnimplementedCLIServer) GetWorkspaceServiceDependencyGraph 

func (UnimplementedCLIServer) GetWorkspaceServiceDependencyGraph(context.Context, *emptypb.Empty) (*v02.GraphResponse, error)

func (UnimplementedCLIServer) Logs 

func (UnimplementedCLIServer) Logs(*emptypb.Empty, CLI_LogsServer) error

func (UnimplementedCLIServer) Ping 

func (UnimplementedCLIServer) Ping(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedCLIServer) StopFlow 

func (UnimplementedCLIServer) StopFlow(context.Context, *StopFlowRequest) (*StopFlowResponse, error)

type UnsafeCLIServer 

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

UnsafeCLIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CLIServer 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.