remote

package
v0.16.3 Latest Latest
Warning

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

 Go to latest Published: Aug 24, 2021 License: MPL-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SetSecretRequest_Type_name = map[int32]string{
		0: "DEVELOPMENT",
		1: "PRODUCTION",
	}
	SetSecretRequest_Type_value = map[string]int32{
		"DEVELOPMENT": 0,
		"PRODUCTION":  1,
	}
)

Enum value maps for SetSecretRequest_Type.

View Source 
var File_encore_server_remote_remote_proto protoreflect.FileDescriptor

Functions

func RegisterRemoteServer 

func RegisterRemoteServer(s *grpc.Server, srv RemoteServer)

Types

type Data 

type Data struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Data) Descriptor deprecated 

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

Deprecated: Use Data.ProtoReflect.Descriptor instead.

func (*Data) GetData 

func (x *Data) GetData() []byte

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) ProtoReflect 

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

func (*Data) Reset 

func (x *Data) Reset()

func (*Data) String 

func (x *Data) String() string

type GetSecretsRequest 

type GetSecretsRequest struct {
	AppSlug string `protobuf:"bytes,1,opt,name=app_slug,json=appSlug,proto3" json:"app_slug,omitempty"`
	Poll    bool   `protobuf:"varint,2,opt,name=poll,proto3" json:"poll,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSecretsRequest) Descriptor deprecated 

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

Deprecated: Use GetSecretsRequest.ProtoReflect.Descriptor instead.

func (*GetSecretsRequest) GetAppSlug 

func (x *GetSecretsRequest) GetAppSlug() string

func (*GetSecretsRequest) GetPoll added in v0.16.2 

func (x *GetSecretsRequest) GetPoll() bool

func (*GetSecretsRequest) ProtoMessage 

func (*GetSecretsRequest) ProtoMessage()

func (*GetSecretsRequest) ProtoReflect 

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

func (*GetSecretsRequest) Reset 

func (x *GetSecretsRequest) Reset()

func (*GetSecretsRequest) String 

func (x *GetSecretsRequest) String() string

type GetSecretsResponse 

type GetSecretsResponse struct {
	Secrets []*Secret `protobuf:"bytes,1,rep,name=secrets,proto3" json:"secrets,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSecretsResponse) Descriptor deprecated 

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

Deprecated: Use GetSecretsResponse.ProtoReflect.Descriptor instead.

func (*GetSecretsResponse) GetSecrets 

func (x *GetSecretsResponse) GetSecrets() []*Secret

func (*GetSecretsResponse) ProtoMessage 

func (*GetSecretsResponse) ProtoMessage()

func (*GetSecretsResponse) ProtoReflect 

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

func (*GetSecretsResponse) Reset 

func (x *GetSecretsResponse) Reset()

func (*GetSecretsResponse) String 

func (x *GetSecretsResponse) String() string

type LogsRequest 

type LogsRequest struct {
	AppSlug string `protobuf:"bytes,1,opt,name=app_slug,json=appSlug,proto3" json:"app_slug,omitempty"`
	EnvName string `protobuf:"bytes,2,opt,name=env_name,json=envName,proto3" json:"env_name,omitempty"`
	// contains filtered or unexported fields
}

func (*LogsRequest) Descriptor deprecated 

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

Deprecated: Use LogsRequest.ProtoReflect.Descriptor instead.

func (*LogsRequest) GetAppSlug 

func (x *LogsRequest) GetAppSlug() string

func (*LogsRequest) GetEnvName 

func (x *LogsRequest) GetEnvName() string

func (*LogsRequest) ProtoMessage 

func (*LogsRequest) ProtoMessage()

func (*LogsRequest) ProtoReflect 

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

func (*LogsRequest) Reset 

func (x *LogsRequest) Reset()

func (*LogsRequest) String 

func (x *LogsRequest) String() string

type LogsResponse 

type LogsResponse struct {
	Lines      [][]byte `protobuf:"bytes,1,rep,name=lines,proto3" json:"lines,omitempty"`
	DropNotice bool     `protobuf:"varint,2,opt,name=drop_notice,json=dropNotice,proto3" json:"drop_notice,omitempty"`
	// contains filtered or unexported fields
}

func (*LogsResponse) Descriptor deprecated 

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

Deprecated: Use LogsResponse.ProtoReflect.Descriptor instead.

func (*LogsResponse) GetDropNotice 

func (x *LogsResponse) GetDropNotice() bool

func (*LogsResponse) GetLines 

func (x *LogsResponse) GetLines() [][]byte

func (*LogsResponse) ProtoMessage 

func (*LogsResponse) ProtoMessage()

func (*LogsResponse) ProtoReflect 

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

func (*LogsResponse) Reset 

func (x *LogsResponse) Reset()

func (*LogsResponse) String 

func (x *LogsResponse) String() string

type MetaRequest 

type MetaRequest struct {
	AppSlug string `protobuf:"bytes,1,opt,name=app_slug,json=appSlug,proto3" json:"app_slug,omitempty"`
	EnvName string `protobuf:"bytes,2,opt,name=env_name,json=envName,proto3" json:"env_name,omitempty"`
	// contains filtered or unexported fields
}

func (*MetaRequest) Descriptor deprecated 

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

Deprecated: Use MetaRequest.ProtoReflect.Descriptor instead.

func (*MetaRequest) GetAppSlug 

func (x *MetaRequest) GetAppSlug() string

func (*MetaRequest) GetEnvName 

func (x *MetaRequest) GetEnvName() string

func (*MetaRequest) ProtoMessage 

func (*MetaRequest) ProtoMessage()

func (*MetaRequest) ProtoReflect 

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

func (*MetaRequest) Reset 

func (x *MetaRequest) Reset()

func (*MetaRequest) String 

func (x *MetaRequest) String() string

type RecordTraceRequest 

type RecordTraceRequest struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*RecordTraceRequest) Descriptor deprecated 

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

Deprecated: Use RecordTraceRequest.ProtoReflect.Descriptor instead.

func (*RecordTraceRequest) GetData 

func (x *RecordTraceRequest) GetData() []byte

func (*RecordTraceRequest) ProtoMessage 

func (*RecordTraceRequest) ProtoMessage()

func (*RecordTraceRequest) ProtoReflect 

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

func (*RecordTraceRequest) Reset 

func (x *RecordTraceRequest) Reset()

func (*RecordTraceRequest) String 

func (x *RecordTraceRequest) String() string

type RecordTraceResponse 

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

func (*RecordTraceResponse) Descriptor deprecated 

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

Deprecated: Use RecordTraceResponse.ProtoReflect.Descriptor instead.

func (*RecordTraceResponse) ProtoMessage 

func (*RecordTraceResponse) ProtoMessage()

func (*RecordTraceResponse) ProtoReflect 

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

func (*RecordTraceResponse) Reset 

func (x *RecordTraceResponse) Reset()

func (*RecordTraceResponse) String 

func (x *RecordTraceResponse) String() string

type RemoteClient 

type RemoteClient interface {
	Tunnel(ctx context.Context, opts ...grpc.CallOption) (Remote_TunnelClient, error)
	Meta(ctx context.Context, in *MetaRequest, opts ...grpc.CallOption) (*v1.Data, error)
	DBConnect(ctx context.Context, opts ...grpc.CallOption) (Remote_DBConnectClient, error)
	RecordTrace(ctx context.Context, in *RecordTraceRequest, opts ...grpc.CallOption) (*RecordTraceResponse, error)
	GetSecrets(ctx context.Context, in *GetSecretsRequest, opts ...grpc.CallOption) (*GetSecretsResponse, error)
	SetSecret(ctx context.Context, in *SetSecretRequest, opts ...grpc.CallOption) (*SetSecretResponse, error)
	Logs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (Remote_LogsClient, error)
}

RemoteClient is the client API for Remote 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 NewRemoteClient 

func NewRemoteClient(cc grpc.ClientConnInterface) RemoteClient

type RemoteServer 

type RemoteServer interface {
	Tunnel(Remote_TunnelServer) error
	Meta(context.Context, *MetaRequest) (*v1.Data, error)
	DBConnect(Remote_DBConnectServer) error
	RecordTrace(context.Context, *RecordTraceRequest) (*RecordTraceResponse, error)
	GetSecrets(context.Context, *GetSecretsRequest) (*GetSecretsResponse, error)
	SetSecret(context.Context, *SetSecretRequest) (*SetSecretResponse, error)
	Logs(*LogsRequest, Remote_LogsServer) error
	// contains filtered or unexported methods
}

RemoteServer is the server API for Remote service. All implementations must embed UnimplementedRemoteServer for forward compatibility

type Remote_DBConnectClient 

type Remote_DBConnectClient interface {
	Send(*Data) error
	Recv() (*Data, error)
	grpc.ClientStream
}

type Remote_DBConnectServer 

type Remote_DBConnectServer interface {
	Send(*Data) error
	Recv() (*Data, error)
	grpc.ServerStream
}

type Remote_LogsClient 

type Remote_LogsClient interface {
	Recv() (*LogsResponse, error)
	grpc.ClientStream
}

type Remote_LogsServer 

type Remote_LogsServer interface {
	Send(*LogsResponse) error
	grpc.ServerStream
}

type Remote_TunnelClient 

type Remote_TunnelClient interface {
	Send(*TunnelClientMsg) error
	Recv() (*TunnelServerMsg, error)
	grpc.ClientStream
}

type Remote_TunnelServer 

type Remote_TunnelServer interface {
	Send(*TunnelServerMsg) error
	Recv() (*TunnelClientMsg, error)
	grpc.ServerStream
}

type Secret 

type Secret struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Secret) Descriptor deprecated 

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

Deprecated: Use Secret.ProtoReflect.Descriptor instead.

func (*Secret) GetKey 

func (x *Secret) GetKey() string

func (*Secret) GetValue 

func (x *Secret) GetValue() string

func (*Secret) ProtoMessage 

func (*Secret) ProtoMessage()

func (*Secret) ProtoReflect 

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

func (*Secret) Reset 

func (x *Secret) Reset()

func (*Secret) String 

func (x *Secret) String() string

type SetSecretRequest 

type SetSecretRequest struct {
	AppSlug string                `protobuf:"bytes,1,opt,name=app_slug,json=appSlug,proto3" json:"app_slug,omitempty"`
	Key     string                `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value   string                `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Type    SetSecretRequest_Type `protobuf:"varint,4,opt,name=type,proto3,enum=encore.server.remote.SetSecretRequest_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*SetSecretRequest) Descriptor deprecated 

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

Deprecated: Use SetSecretRequest.ProtoReflect.Descriptor instead.

func (*SetSecretRequest) GetAppSlug 

func (x *SetSecretRequest) GetAppSlug() string

func (*SetSecretRequest) GetKey 

func (x *SetSecretRequest) GetKey() string

func (*SetSecretRequest) GetType 

func (x *SetSecretRequest) GetType() SetSecretRequest_Type

func (*SetSecretRequest) GetValue 

func (x *SetSecretRequest) GetValue() string

func (*SetSecretRequest) ProtoMessage 

func (*SetSecretRequest) ProtoMessage()

func (*SetSecretRequest) ProtoReflect 

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

func (*SetSecretRequest) Reset 

func (x *SetSecretRequest) Reset()

func (*SetSecretRequest) String 

func (x *SetSecretRequest) String() string

type SetSecretRequest_Type 

type SetSecretRequest_Type int32
const (
	SetSecretRequest_DEVELOPMENT SetSecretRequest_Type = 0
	SetSecretRequest_PRODUCTION  SetSecretRequest_Type = 1
)

func (SetSecretRequest_Type) Descriptor 

func (SetSecretRequest_Type) Descriptor() protoreflect.EnumDescriptor

func (SetSecretRequest_Type) Enum 

func (x SetSecretRequest_Type) Enum() *SetSecretRequest_Type

func (SetSecretRequest_Type) EnumDescriptor deprecated 

func (SetSecretRequest_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use SetSecretRequest_Type.Descriptor instead.

func (SetSecretRequest_Type) Number 

func (x SetSecretRequest_Type) Number() protoreflect.EnumNumber

func (SetSecretRequest_Type) String 

func (x SetSecretRequest_Type) String() string

func (SetSecretRequest_Type) Type 

func (SetSecretRequest_Type) Type() protoreflect.EnumType

type SetSecretResponse 

type SetSecretResponse struct {
	Created bool `protobuf:"varint,1,opt,name=created,proto3" json:"created,omitempty"` // whether or not the secret was created (as opposed to updated)
	// contains filtered or unexported fields
}

func (*SetSecretResponse) Descriptor deprecated 

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

Deprecated: Use SetSecretResponse.ProtoReflect.Descriptor instead.

func (*SetSecretResponse) GetCreated 

func (x *SetSecretResponse) GetCreated() bool

func (*SetSecretResponse) ProtoMessage 

func (*SetSecretResponse) ProtoMessage()

func (*SetSecretResponse) ProtoReflect 

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

func (*SetSecretResponse) Reset 

func (x *SetSecretResponse) Reset()

func (*SetSecretResponse) String 

func (x *SetSecretResponse) String() string

type TunnelClientMsg 

type TunnelClientMsg struct {

	// Types that are assignable to Msg:
	//	*TunnelClientMsg_Setup
	//	*TunnelClientMsg_Rpc
	Msg isTunnelClientMsg_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

func (*TunnelClientMsg) Descriptor deprecated 

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

Deprecated: Use TunnelClientMsg.ProtoReflect.Descriptor instead.

func (*TunnelClientMsg) GetMsg 

func (m *TunnelClientMsg) GetMsg() isTunnelClientMsg_Msg

func (*TunnelClientMsg) GetRpc 

func (x *TunnelClientMsg) GetRpc() *tunnel.RPCResp

func (*TunnelClientMsg) GetSetup 

func (x *TunnelClientMsg) GetSetup() *tunnel.SetupReq

func (*TunnelClientMsg) ProtoMessage 

func (*TunnelClientMsg) ProtoMessage()

func (*TunnelClientMsg) ProtoReflect 

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

func (*TunnelClientMsg) Reset 

func (x *TunnelClientMsg) Reset()

func (*TunnelClientMsg) String 

func (x *TunnelClientMsg) String() string

type TunnelClientMsg_Rpc 

type TunnelClientMsg_Rpc struct {
	Rpc *tunnel.RPCResp `protobuf:"bytes,2,opt,name=rpc,proto3,oneof"`
}

type TunnelClientMsg_Setup 

type TunnelClientMsg_Setup struct {
	Setup *tunnel.SetupReq `protobuf:"bytes,1,opt,name=setup,proto3,oneof"`
}

type TunnelServerMsg 

type TunnelServerMsg struct {

	// Types that are assignable to Msg:
	//	*TunnelServerMsg_Setup
	//	*TunnelServerMsg_Rpc
	Msg isTunnelServerMsg_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

func (*TunnelServerMsg) Descriptor deprecated 

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

Deprecated: Use TunnelServerMsg.ProtoReflect.Descriptor instead.

func (*TunnelServerMsg) GetMsg 

func (m *TunnelServerMsg) GetMsg() isTunnelServerMsg_Msg

func (*TunnelServerMsg) GetRpc 

func (x *TunnelServerMsg) GetRpc() *tunnel.RPCReq

func (*TunnelServerMsg) GetSetup 

func (x *TunnelServerMsg) GetSetup() *tunnel.SetupResp

func (*TunnelServerMsg) ProtoMessage 

func (*TunnelServerMsg) ProtoMessage()

func (*TunnelServerMsg) ProtoReflect 

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

func (*TunnelServerMsg) Reset 

func (x *TunnelServerMsg) Reset()

func (*TunnelServerMsg) String 

func (x *TunnelServerMsg) String() string

type TunnelServerMsg_Rpc 

type TunnelServerMsg_Rpc struct {
	Rpc *tunnel.RPCReq `protobuf:"bytes,2,opt,name=rpc,proto3,oneof"`
}

type TunnelServerMsg_Setup 

type TunnelServerMsg_Setup struct {
	Setup *tunnel.SetupResp `protobuf:"bytes,1,opt,name=setup,proto3,oneof"`
}

type UnimplementedRemoteServer 

type UnimplementedRemoteServer struct {
}

UnimplementedRemoteServer must be embedded to have forward compatible implementations.

func (*UnimplementedRemoteServer) DBConnect 

func (*UnimplementedRemoteServer) DBConnect(Remote_DBConnectServer) error

func (*UnimplementedRemoteServer) GetSecrets 

func (*UnimplementedRemoteServer) GetSecrets(context.Context, *GetSecretsRequest) (*GetSecretsResponse, error)

func (*UnimplementedRemoteServer) Logs 

func (*UnimplementedRemoteServer) Logs(*LogsRequest, Remote_LogsServer) error

func (*UnimplementedRemoteServer) Meta 

func (*UnimplementedRemoteServer) Meta(context.Context, *MetaRequest) (*v1.Data, error)

func (*UnimplementedRemoteServer) RecordTrace 

func (*UnimplementedRemoteServer) RecordTrace(context.Context, *RecordTraceRequest) (*RecordTraceResponse, error)

func (*UnimplementedRemoteServer) SetSecret 

func (*UnimplementedRemoteServer) SetSecret(context.Context, *SetSecretRequest) (*SetSecretResponse, error)

func (*UnimplementedRemoteServer) Tunnel 

func (*UnimplementedRemoteServer) Tunnel(Remote_TunnelServer) error

Source Files

View all Source files

Directories

Path Synopsis

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.