node

package
v0.0.0-...-60f4931 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterControllerServer 

func RegisterControllerServer(s *grpc.Server, srv ControllerServer)

Types

type ControllerClient 

type ControllerClient interface {
	Tunnel(ctx context.Context, opts ...grpc.CallOption) (Controller_TunnelClient, error)
	ExposedTunnel(ctx context.Context, opts ...grpc.CallOption) (Controller_ExposedTunnelClient, error)
	// The request and responses are flipped because the node controller is
	// querying the CLI for status updates, but the CLI is initiating the
	// connection.
	SyncNotifications(ctx context.Context, opts ...grpc.CallOption) (Controller_SyncNotificationsClient, error)
}

ControllerClient is the client API for Controller service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewControllerClient 

func NewControllerClient(cc grpc.ClientConnInterface) ControllerClient

type ControllerServer 

type ControllerServer interface {
	Tunnel(Controller_TunnelServer) error
	ExposedTunnel(Controller_ExposedTunnelServer) error
	// The request and responses are flipped because the node controller is
	// querying the CLI for status updates, but the CLI is initiating the
	// connection.
	SyncNotifications(Controller_SyncNotificationsServer) error
}

ControllerServer is the server API for Controller service.

type Controller_ExposedTunnelClient 

type Controller_ExposedTunnelClient interface {
	Send(*TunnelMsg) error
	Recv() (*TunnelMsg, error)
	grpc.ClientStream
}

type Controller_ExposedTunnelServer 

type Controller_ExposedTunnelServer interface {
	Send(*TunnelMsg) error
	Recv() (*TunnelMsg, error)
	grpc.ServerStream
}

type Controller_SyncNotificationsClient 

type Controller_SyncNotificationsClient interface {
	Send(*SyncStatusResponse) error
	Recv() (*GetSyncStatusRequest, error)
	grpc.ClientStream
}

type Controller_SyncNotificationsServer 

type Controller_SyncNotificationsServer interface {
	Send(*GetSyncStatusRequest) error
	Recv() (*SyncStatusResponse, error)
	grpc.ServerStream
}

type Controller_TunnelClient 

type Controller_TunnelClient interface {
	Send(*TunnelMsg) error
	Recv() (*TunnelMsg, error)
	grpc.ClientStream
}

type Controller_TunnelServer 

type Controller_TunnelServer interface {
	Send(*TunnelMsg) error
	Recv() (*TunnelMsg, error)
	grpc.ServerStream
}

type EOF 

type EOF struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EOF) Descriptor 

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

func (*EOF) ProtoMessage 

func (*EOF) ProtoMessage()

func (*EOF) Reset 

func (m *EOF) Reset()

func (*EOF) String 

func (m *EOF) String() string

func (*EOF) XXX_DiscardUnknown 

func (m *EOF) XXX_DiscardUnknown()

func (*EOF) XXX_Marshal 

func (m *EOF) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EOF) XXX_Merge 

func (m *EOF) XXX_Merge(src proto.Message)

func (*EOF) XXX_Size 

func (m *EOF) XXX_Size() int

func (*EOF) XXX_Unmarshal 

func (m *EOF) XXX_Unmarshal(b []byte) error

type ExposedTunnelHeader 

type ExposedTunnelHeader struct {
	Token                string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExposedTunnelHeader) Descriptor 

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

func (*ExposedTunnelHeader) GetNamespace 

func (m *ExposedTunnelHeader) GetNamespace() string

func (*ExposedTunnelHeader) GetToken 

func (m *ExposedTunnelHeader) GetToken() string

func (*ExposedTunnelHeader) ProtoMessage 

func (*ExposedTunnelHeader) ProtoMessage()

func (*ExposedTunnelHeader) Reset 

func (m *ExposedTunnelHeader) Reset()

func (*ExposedTunnelHeader) String 

func (m *ExposedTunnelHeader) String() string

func (*ExposedTunnelHeader) XXX_DiscardUnknown 

func (m *ExposedTunnelHeader) XXX_DiscardUnknown()

func (*ExposedTunnelHeader) XXX_Marshal 

func (m *ExposedTunnelHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExposedTunnelHeader) XXX_Merge 

func (m *ExposedTunnelHeader) XXX_Merge(src proto.Message)

func (*ExposedTunnelHeader) XXX_Size 

func (m *ExposedTunnelHeader) XXX_Size() int

func (*ExposedTunnelHeader) XXX_Unmarshal 

func (m *ExposedTunnelHeader) XXX_Unmarshal(b []byte) error

type GetSyncStatusRequest 

type GetSyncStatusRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSyncStatusRequest) Descriptor 

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

func (*GetSyncStatusRequest) ProtoMessage 

func (*GetSyncStatusRequest) ProtoMessage()

func (*GetSyncStatusRequest) Reset 

func (m *GetSyncStatusRequest) Reset()

func (*GetSyncStatusRequest) String 

func (m *GetSyncStatusRequest) String() string

func (*GetSyncStatusRequest) XXX_DiscardUnknown 

func (m *GetSyncStatusRequest) XXX_DiscardUnknown()

func (*GetSyncStatusRequest) XXX_Marshal 

func (m *GetSyncStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSyncStatusRequest) XXX_Merge 

func (m *GetSyncStatusRequest) XXX_Merge(src proto.Message)

func (*GetSyncStatusRequest) XXX_Size 

func (m *GetSyncStatusRequest) XXX_Size() int

func (*GetSyncStatusRequest) XXX_Unmarshal 

func (m *GetSyncStatusRequest) XXX_Unmarshal(b []byte) error

type SyncStatusResponse 

type SyncStatusResponse struct {
	// Types that are valid to be assigned to Msg:
	//	*SyncStatusResponse_OldToken
	//	*SyncStatusResponse_Auth
	//	*SyncStatusResponse_Synced
	Msg                  isSyncStatusResponse_Msg `protobuf_oneof:"msg"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*SyncStatusResponse) Descriptor 

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

func (*SyncStatusResponse) GetAuth 

func (m *SyncStatusResponse) GetAuth() *auth.BlimpAuth

func (*SyncStatusResponse) GetMsg 

func (m *SyncStatusResponse) GetMsg() isSyncStatusResponse_Msg

func (*SyncStatusResponse) GetOldToken 

func (m *SyncStatusResponse) GetOldToken() string

func (*SyncStatusResponse) GetSynced 

func (m *SyncStatusResponse) GetSynced() bool

func (*SyncStatusResponse) ProtoMessage 

func (*SyncStatusResponse) ProtoMessage()

func (*SyncStatusResponse) Reset 

func (m *SyncStatusResponse) Reset()

func (*SyncStatusResponse) String 

func (m *SyncStatusResponse) String() string

func (*SyncStatusResponse) XXX_DiscardUnknown 

func (m *SyncStatusResponse) XXX_DiscardUnknown()

func (*SyncStatusResponse) XXX_Marshal 

func (m *SyncStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncStatusResponse) XXX_Merge 

func (m *SyncStatusResponse) XXX_Merge(src proto.Message)

func (*SyncStatusResponse) XXX_OneofWrappers 

func (*SyncStatusResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SyncStatusResponse) XXX_Size 

func (m *SyncStatusResponse) XXX_Size() int

func (*SyncStatusResponse) XXX_Unmarshal 

func (m *SyncStatusResponse) XXX_Unmarshal(b []byte) error

type SyncStatusResponse_Auth 

type SyncStatusResponse_Auth struct {
	Auth *auth.BlimpAuth `protobuf:"bytes,3,opt,name=auth,proto3,oneof"`
}

type SyncStatusResponse_OldToken 

type SyncStatusResponse_OldToken struct {
	OldToken string `protobuf:"bytes,1,opt,name=old_token,json=oldToken,proto3,oneof"`
}

type SyncStatusResponse_Synced 

type SyncStatusResponse_Synced struct {
	Synced bool `protobuf:"varint,2,opt,name=synced,proto3,oneof"`
}

type TunnelHeader 

type TunnelHeader struct {
	Name                 string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Port                 uint32          `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	OldToken             string          `protobuf:"bytes,3,opt,name=old_token,json=oldToken,proto3" json:"old_token,omitempty"`
	Auth                 *auth.BlimpAuth `protobuf:"bytes,5,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*TunnelHeader) Descriptor 

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

func (*TunnelHeader) GetAuth 

func (m *TunnelHeader) GetAuth() *auth.BlimpAuth

func (*TunnelHeader) GetName 

func (m *TunnelHeader) GetName() string

func (*TunnelHeader) GetOldToken 

func (m *TunnelHeader) GetOldToken() string

func (*TunnelHeader) GetPort 

func (m *TunnelHeader) GetPort() uint32

func (*TunnelHeader) ProtoMessage 

func (*TunnelHeader) ProtoMessage()

func (*TunnelHeader) Reset 

func (m *TunnelHeader) Reset()

func (*TunnelHeader) String 

func (m *TunnelHeader) String() string

func (*TunnelHeader) XXX_DiscardUnknown 

func (m *TunnelHeader) XXX_DiscardUnknown()

func (*TunnelHeader) XXX_Marshal 

func (m *TunnelHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TunnelHeader) XXX_Merge 

func (m *TunnelHeader) XXX_Merge(src proto.Message)

func (*TunnelHeader) XXX_Size 

func (m *TunnelHeader) XXX_Size() int

func (*TunnelHeader) XXX_Unmarshal 

func (m *TunnelHeader) XXX_Unmarshal(b []byte) error

type TunnelMsg 

type TunnelMsg struct {
	// Types that are valid to be assigned to Msg:
	//	*TunnelMsg_Error
	//	*TunnelMsg_Header
	//	*TunnelMsg_ExposedHeader
	//	*TunnelMsg_Buf
	//	*TunnelMsg_Eof
	Msg                  isTunnelMsg_Msg `protobuf_oneof:"msg"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

The first message the Client sends to the server must be a header. After that all messages either direction must be bufs. Optionally, either direction may send an EOF to indicate they have no more to send.

func (*TunnelMsg) Descriptor 

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

func (*TunnelMsg) GetBuf 

func (m *TunnelMsg) GetBuf() []byte

func (*TunnelMsg) GetEof 

func (m *TunnelMsg) GetEof() *EOF

func (*TunnelMsg) GetError 

func (m *TunnelMsg) GetError() *errors.Error

func (*TunnelMsg) GetExposedHeader 

func (m *TunnelMsg) GetExposedHeader() *ExposedTunnelHeader

func (*TunnelMsg) GetHeader 

func (m *TunnelMsg) GetHeader() *TunnelHeader

func (*TunnelMsg) GetMsg 

func (m *TunnelMsg) GetMsg() isTunnelMsg_Msg

func (*TunnelMsg) ProtoMessage 

func (*TunnelMsg) ProtoMessage()

func (*TunnelMsg) Reset 

func (m *TunnelMsg) Reset()

func (*TunnelMsg) String 

func (m *TunnelMsg) String() string

func (*TunnelMsg) XXX_DiscardUnknown 

func (m *TunnelMsg) XXX_DiscardUnknown()

func (*TunnelMsg) XXX_Marshal 

func (m *TunnelMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TunnelMsg) XXX_Merge 

func (m *TunnelMsg) XXX_Merge(src proto.Message)

func (*TunnelMsg) XXX_OneofWrappers 

func (*TunnelMsg) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TunnelMsg) XXX_Size 

func (m *TunnelMsg) XXX_Size() int

func (*TunnelMsg) XXX_Unmarshal 

func (m *TunnelMsg) XXX_Unmarshal(b []byte) error

type TunnelMsg_Buf 

type TunnelMsg_Buf struct {
	Buf []byte `protobuf:"bytes,3,opt,name=buf,proto3,oneof"`
}

type TunnelMsg_Eof 

type TunnelMsg_Eof struct {
	Eof *EOF `protobuf:"bytes,4,opt,name=eof,proto3,oneof"`
}

type TunnelMsg_Error 

type TunnelMsg_Error struct {
	Error *errors.Error `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type TunnelMsg_ExposedHeader 

type TunnelMsg_ExposedHeader struct {
	ExposedHeader *ExposedTunnelHeader `protobuf:"bytes,5,opt,name=exposed_header,json=exposedHeader,proto3,oneof"`
}

type TunnelMsg_Header 

type TunnelMsg_Header struct {
	Header *TunnelHeader `protobuf:"bytes,2,opt,name=header,proto3,oneof"`
}

type UnimplementedControllerServer 

type UnimplementedControllerServer struct {
}

UnimplementedControllerServer can be embedded to have forward compatible implementations.

func (*UnimplementedControllerServer) ExposedTunnel 

func (*UnimplementedControllerServer) ExposedTunnel(srv Controller_ExposedTunnelServer) error

func (*UnimplementedControllerServer) SyncNotifications 

func (*UnimplementedControllerServer) SyncNotifications(srv Controller_SyncNotificationsServer) error

func (*UnimplementedControllerServer) Tunnel 

func (*UnimplementedControllerServer) Tunnel(srv Controller_TunnelServer) error

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.