clientapi

package
v1.1.3 Latest Latest
Warning

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

 Go to latest Published: Apr 22, 2021 License: Apache-2.0 Imports: 12 Imported by: 2

README

Dev

Note: Below instructions are for Ubuntu 16.04. Please modify for other platforms accordingly.

If you make changes to api.proto, please regenerate api.pb.go by following below steps.

  1. Download protoc version 3.0 from here.

  2. Place protoc binary in your PATH.

  3. Install protoc-gen-go.

go get github.com/golang/protobuf/protoc-gen-go

This would place protoc-gen-go binary in your $GOROOT/bin. Verify $GOROOT/bin is in your $PATH.

# env | grep PATH
PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/snap/bin:/root/gostuff/bin
GOPATH=/root/gostuff
  1. Run protoc to generate clientapi.pb.go.
protoc -I=$PWD --go_out=plugins=grpc:.  $PWD/clientapi.proto

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterKipServer 

func RegisterKipServer(s *grpc.Server, srv KipServer)

Types

type APIReply 

type APIReply struct {
	Status int32  `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Body   []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// Warnings are printed by the client to stderr
	Warning              []byte   `protobuf:"bytes,3,opt,name=warning,proto3" json:"warning,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*APIReply) Descriptor 

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

func (*APIReply) GetBody 

func (m *APIReply) GetBody() []byte

func (*APIReply) GetStatus 

func (m *APIReply) GetStatus() int32

func (*APIReply) GetWarning 

func (m *APIReply) GetWarning() []byte

func (*APIReply) ProtoMessage 

func (*APIReply) ProtoMessage()

func (*APIReply) Reset 

func (m *APIReply) Reset()

func (*APIReply) String 

func (m *APIReply) String() string

func (*APIReply) XXX_DiscardUnknown 

func (m *APIReply) XXX_DiscardUnknown()

func (*APIReply) XXX_Marshal 

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

func (*APIReply) XXX_Merge 

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

func (*APIReply) XXX_Size 

func (m *APIReply) XXX_Size() int

func (*APIReply) XXX_Unmarshal 

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

type ConsoleStreamMsg 

type ConsoleStreamMsg struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConsoleStreamMsg) Descriptor 

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

func (*ConsoleStreamMsg) GetData 

func (m *ConsoleStreamMsg) GetData() []byte

func (*ConsoleStreamMsg) ProtoMessage 

func (*ConsoleStreamMsg) ProtoMessage()

func (*ConsoleStreamMsg) Reset 

func (m *ConsoleStreamMsg) Reset()

func (*ConsoleStreamMsg) String 

func (m *ConsoleStreamMsg) String() string

func (*ConsoleStreamMsg) XXX_DiscardUnknown 

func (m *ConsoleStreamMsg) XXX_DiscardUnknown()

func (*ConsoleStreamMsg) XXX_Marshal 

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

func (*ConsoleStreamMsg) XXX_Merge 

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

func (*ConsoleStreamMsg) XXX_Size 

func (m *ConsoleStreamMsg) XXX_Size() int

func (*ConsoleStreamMsg) XXX_Unmarshal 

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

type CreateRequest 

type CreateRequest struct {
	Manifest             []byte   `protobuf:"bytes,1,opt,name=manifest,proto3" json:"manifest,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateRequest) Descriptor 

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

func (*CreateRequest) GetManifest 

func (m *CreateRequest) GetManifest() []byte

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) String 

func (m *CreateRequest) String() string

func (*CreateRequest) XXX_DiscardUnknown 

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal 

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

func (*CreateRequest) XXX_Merge 

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

func (*CreateRequest) XXX_Size 

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal 

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

type DeleteRequest 

type DeleteRequest struct {
	Kind                 []byte   `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Name                 []byte   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Cascade              bool     `protobuf:"varint,3,opt,name=cascade,proto3" json:"cascade,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetCascade 

func (m *DeleteRequest) GetCascade() bool

func (*DeleteRequest) GetKind 

func (m *DeleteRequest) GetKind() []byte

func (*DeleteRequest) GetName 

func (m *DeleteRequest) GetName() []byte

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

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

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

type DeployRequest 

type DeployRequest struct {
	ResourceName         string   `protobuf:"bytes,1,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	ItemName             string   `protobuf:"bytes,2,opt,name=itemName,proto3" json:"itemName,omitempty"`
	PackageData          []byte   `protobuf:"bytes,3,opt,name=packageData,proto3" json:"packageData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeployRequest) Descriptor 

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

func (*DeployRequest) GetItemName 

func (m *DeployRequest) GetItemName() string

func (*DeployRequest) GetPackageData 

func (m *DeployRequest) GetPackageData() []byte

func (*DeployRequest) GetResourceName 

func (m *DeployRequest) GetResourceName() string

func (*DeployRequest) ProtoMessage 

func (*DeployRequest) ProtoMessage()

func (*DeployRequest) Reset 

func (m *DeployRequest) Reset()

func (*DeployRequest) String 

func (m *DeployRequest) String() string

func (*DeployRequest) XXX_DiscardUnknown 

func (m *DeployRequest) XXX_DiscardUnknown()

func (*DeployRequest) XXX_Marshal 

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

func (*DeployRequest) XXX_Merge 

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

func (*DeployRequest) XXX_Size 

func (m *DeployRequest) XXX_Size() int

func (*DeployRequest) XXX_Unmarshal 

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

type DumpRequest 

type DumpRequest struct {
	Kind                 []byte   `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DumpRequest) Descriptor 

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

func (*DumpRequest) GetKind 

func (m *DumpRequest) GetKind() []byte

func (*DumpRequest) ProtoMessage 

func (*DumpRequest) ProtoMessage()

func (*DumpRequest) Reset 

func (m *DumpRequest) Reset()

func (*DumpRequest) String 

func (m *DumpRequest) String() string

func (*DumpRequest) XXX_DiscardUnknown 

func (m *DumpRequest) XXX_DiscardUnknown()

func (*DumpRequest) XXX_Marshal 

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

func (*DumpRequest) XXX_Merge 

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

func (*DumpRequest) XXX_Size 

func (m *DumpRequest) XXX_Size() int

func (*DumpRequest) XXX_Unmarshal 

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

type GetRequest 

type GetRequest struct {
	Kind                 []byte   `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Name                 []byte   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetKind 

func (m *GetRequest) GetKind() []byte

func (*GetRequest) GetName 

func (m *GetRequest) GetName() []byte

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type IsLeaderReply 

type IsLeaderReply struct {
	IsLeader             bool     `protobuf:"varint,1,opt,name=isLeader,proto3" json:"isLeader,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IsLeaderReply) Descriptor 

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

func (*IsLeaderReply) GetIsLeader 

func (m *IsLeaderReply) GetIsLeader() bool

func (*IsLeaderReply) ProtoMessage 

func (*IsLeaderReply) ProtoMessage()

func (*IsLeaderReply) Reset 

func (m *IsLeaderReply) Reset()

func (*IsLeaderReply) String 

func (m *IsLeaderReply) String() string

func (*IsLeaderReply) XXX_DiscardUnknown 

func (m *IsLeaderReply) XXX_DiscardUnknown()

func (*IsLeaderReply) XXX_Marshal 

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

func (*IsLeaderReply) XXX_Merge 

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

func (*IsLeaderReply) XXX_Size 

func (m *IsLeaderReply) XXX_Size() int

func (*IsLeaderReply) XXX_Unmarshal 

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

type IsLeaderRequest 

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

func (*IsLeaderRequest) Descriptor 

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

func (*IsLeaderRequest) ProtoMessage 

func (*IsLeaderRequest) ProtoMessage()

func (*IsLeaderRequest) Reset 

func (m *IsLeaderRequest) Reset()

func (*IsLeaderRequest) String 

func (m *IsLeaderRequest) String() string

func (*IsLeaderRequest) XXX_DiscardUnknown 

func (m *IsLeaderRequest) XXX_DiscardUnknown()

func (*IsLeaderRequest) XXX_Marshal 

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

func (*IsLeaderRequest) XXX_Merge 

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

func (*IsLeaderRequest) XXX_Size 

func (m *IsLeaderRequest) XXX_Size() int

func (*IsLeaderRequest) XXX_Unmarshal 

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

type KipClient 

type KipClient interface {
	// Get Server Version.
	GetVersion(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionReply, error)
	// Asks the server if it is the leader.
	IsLeader(ctx context.Context, in *IsLeaderRequest, opts ...grpc.CallOption) (*IsLeaderReply, error)
	// Create given resource on cloud backend.
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*APIReply, error)
	// Update given resource on cloud backend.
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*APIReply, error)
	// Get the given resource
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*APIReply, error)
	// Get the given resource
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*APIReply, error)
	// Get logs of a given pod.
	GetLogs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (*APIReply, error)
	// Dump controller status.
	Dump(ctx context.Context, in *DumpRequest, opts ...grpc.CallOption) (*APIReply, error)
	// Deploy a Kip package for a unit in a running pod.
	Deploy(ctx context.Context, opts ...grpc.CallOption) (Kip_DeployClient, error)
	// Stream logs from a running pod
	StreamLogs(ctx context.Context, in *StreamLogsRequest, opts ...grpc.CallOption) (Kip_StreamLogsClient, error)
	// Execute a command in the context of a unit
	Exec(ctx context.Context, opts ...grpc.CallOption) (Kip_ExecClient, error)
	// Attach to stdin, stdout and stderr of a running pod
	Attach(ctx context.Context, opts ...grpc.CallOption) (Kip_AttachClient, error)
}

KipClient is the client API for Kip service.

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

func NewKipClient 

func NewKipClient(cc *grpc.ClientConn) KipClient

type KipServer 

type KipServer interface {
	// Get Server Version.
	GetVersion(context.Context, *VersionRequest) (*VersionReply, error)
	// Asks the server if it is the leader.
	IsLeader(context.Context, *IsLeaderRequest) (*IsLeaderReply, error)
	// Create given resource on cloud backend.
	Create(context.Context, *CreateRequest) (*APIReply, error)
	// Update given resource on cloud backend.
	Update(context.Context, *UpdateRequest) (*APIReply, error)
	// Get the given resource
	Get(context.Context, *GetRequest) (*APIReply, error)
	// Get the given resource
	Delete(context.Context, *DeleteRequest) (*APIReply, error)
	// Get logs of a given pod.
	GetLogs(context.Context, *LogsRequest) (*APIReply, error)
	// Dump controller status.
	Dump(context.Context, *DumpRequest) (*APIReply, error)
	// Deploy a Kip package for a unit in a running pod.
	Deploy(Kip_DeployServer) error
	// Stream logs from a running pod
	StreamLogs(*StreamLogsRequest, Kip_StreamLogsServer) error
	// Execute a command in the context of a unit
	Exec(Kip_ExecServer) error
	// Attach to stdin, stdout and stderr of a running pod
	Attach(Kip_AttachServer) error
}

KipServer is the server API for Kip service.

type Kip_AttachClient 

type Kip_AttachClient interface {
	Send(*StreamMsg) error
	Recv() (*StreamMsg, error)
	grpc.ClientStream
}

type Kip_AttachServer 

type Kip_AttachServer interface {
	Send(*StreamMsg) error
	Recv() (*StreamMsg, error)
	grpc.ServerStream
}

type Kip_DeployClient 

type Kip_DeployClient interface {
	Send(*DeployRequest) error
	CloseAndRecv() (*APIReply, error)
	grpc.ClientStream
}

type Kip_DeployServer 

type Kip_DeployServer interface {
	SendAndClose(*APIReply) error
	Recv() (*DeployRequest, error)
	grpc.ServerStream
}

type Kip_ExecClient 

type Kip_ExecClient interface {
	Send(*StreamMsg) error
	Recv() (*StreamMsg, error)
	grpc.ClientStream
}

type Kip_ExecServer 

type Kip_ExecServer interface {
	Send(*StreamMsg) error
	Recv() (*StreamMsg, error)
	grpc.ServerStream
}

type Kip_StreamLogsClient 

type Kip_StreamLogsClient interface {
	Recv() (*StreamMsg, error)
	grpc.ClientStream
}

type Kip_StreamLogsServer 

type Kip_StreamLogsServer interface {
	Send(*StreamMsg) error
	grpc.ServerStream
}

type LogsRequest 

type LogsRequest struct {
	ResourceName         string   `protobuf:"bytes,1,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	ItemName             string   `protobuf:"bytes,2,opt,name=itemName,proto3" json:"itemName,omitempty"`
	Lines                int32    `protobuf:"varint,3,opt,name=lines,proto3" json:"lines,omitempty"`
	Limitbytes           int32    `protobuf:"varint,4,opt,name=limitbytes,proto3" json:"limitbytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogsRequest) Descriptor 

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

func (*LogsRequest) GetItemName 

func (m *LogsRequest) GetItemName() string

func (*LogsRequest) GetLimitbytes 

func (m *LogsRequest) GetLimitbytes() int32

func (*LogsRequest) GetLines 

func (m *LogsRequest) GetLines() int32

func (*LogsRequest) GetResourceName 

func (m *LogsRequest) GetResourceName() string

func (*LogsRequest) ProtoMessage 

func (*LogsRequest) ProtoMessage()

func (*LogsRequest) Reset 

func (m *LogsRequest) Reset()

func (*LogsRequest) String 

func (m *LogsRequest) String() string

func (*LogsRequest) XXX_DiscardUnknown 

func (m *LogsRequest) XXX_DiscardUnknown()

func (*LogsRequest) XXX_Marshal 

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

func (*LogsRequest) XXX_Merge 

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

func (*LogsRequest) XXX_Size 

func (m *LogsRequest) XXX_Size() int

func (*LogsRequest) XXX_Unmarshal 

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

type MockKipClient 

type MockKipClient struct {
	GetVersioner func(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionReply, error)
	Creator      func(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*APIReply, error)
	Updater      func(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*APIReply, error)
	Getter       func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*APIReply, error)
	Deleter      func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*APIReply, error)
	GetLogser    func(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (*APIReply, error)
	Dumper       func(ctx context.Context, in *DumpRequest, opts ...grpc.CallOption) (*APIReply, error)
	Deployer     func(ctx context.Context, opts ...grpc.CallOption) (Kip_DeployClient, error)
	StreamLogser func(ctx context.Context, in *StreamLogsRequest, opts ...grpc.CallOption) (Kip_StreamLogsClient, error)
	Execer       func(ctx context.Context, opts ...grpc.CallOption) (Kip_ExecClient, error)
	Attacher     func(ctx context.Context, opts ...grpc.CallOption) (Kip_AttachClient, error)
	Leader       func(ctx context.Context, in *IsLeaderRequest, opts ...grpc.CallOption) (*IsLeaderReply, error)
}

func NewMockKipClient 

func NewMockKipClient() MockKipClient

func (MockKipClient) Attach 

func (m MockKipClient) Attach(ctx context.Context, opts ...grpc.CallOption) (Kip_AttachClient, error)

func (MockKipClient) Create 

func (m MockKipClient) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*APIReply, error)

func (MockKipClient) Delete 

func (m MockKipClient) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*APIReply, error)

func (MockKipClient) Deploy 

func (m MockKipClient) Deploy(ctx context.Context, opts ...grpc.CallOption) (Kip_DeployClient, error)

func (MockKipClient) Dump 

func (m MockKipClient) Dump(ctx context.Context, in *DumpRequest, opts ...grpc.CallOption) (*APIReply, error)

func (MockKipClient) Exec 

func (m MockKipClient) Exec(ctx context.Context, opts ...grpc.CallOption) (Kip_ExecClient, error)

func (MockKipClient) Get 

func (m MockKipClient) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*APIReply, error)

func (MockKipClient) GetLogs 

func (m MockKipClient) GetLogs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (*APIReply, error)

func (MockKipClient) GetVersion 

func (m MockKipClient) GetVersion(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionReply, error)

func (MockKipClient) IsLeader 

func (m MockKipClient) IsLeader(ctx context.Context, in *IsLeaderRequest, opts ...grpc.CallOption) (*IsLeaderReply, error)

func (MockKipClient) StreamLogs 

func (m MockKipClient) StreamLogs(ctx context.Context, in *StreamLogsRequest, opts ...grpc.CallOption) (Kip_StreamLogsClient, error)

func (MockKipClient) Update 

func (m MockKipClient) Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*APIReply, error)

type StreamLogsRequest 

type StreamLogsRequest struct {
	Pod                  string   `protobuf:"bytes,1,opt,name=Pod,proto3" json:"Pod,omitempty"`
	Unit                 string   `protobuf:"bytes,2,opt,name=Unit,proto3" json:"Unit,omitempty"`
	Metadata             bool     `protobuf:"varint,3,opt,name=Metadata,proto3" json:"Metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamLogsRequest) Descriptor 

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

func (*StreamLogsRequest) GetMetadata 

func (m *StreamLogsRequest) GetMetadata() bool

func (*StreamLogsRequest) GetPod 

func (m *StreamLogsRequest) GetPod() string

func (*StreamLogsRequest) GetUnit 

func (m *StreamLogsRequest) GetUnit() string

func (*StreamLogsRequest) ProtoMessage 

func (*StreamLogsRequest) ProtoMessage()

func (*StreamLogsRequest) Reset 

func (m *StreamLogsRequest) Reset()

func (*StreamLogsRequest) String 

func (m *StreamLogsRequest) String() string

func (*StreamLogsRequest) XXX_DiscardUnknown 

func (m *StreamLogsRequest) XXX_DiscardUnknown()

func (*StreamLogsRequest) XXX_Marshal 

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

func (*StreamLogsRequest) XXX_Merge 

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

func (*StreamLogsRequest) XXX_Size 

func (m *StreamLogsRequest) XXX_Size() int

func (*StreamLogsRequest) XXX_Unmarshal 

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

type StreamMsg 

type StreamMsg struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
	Error                []byte   `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamMsg) Descriptor 

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

func (*StreamMsg) GetData 

func (m *StreamMsg) GetData() []byte

func (*StreamMsg) GetError 

func (m *StreamMsg) GetError() []byte

func (*StreamMsg) ProtoMessage 

func (*StreamMsg) ProtoMessage()

func (*StreamMsg) Reset 

func (m *StreamMsg) Reset()

func (*StreamMsg) String 

func (m *StreamMsg) String() string

func (*StreamMsg) XXX_DiscardUnknown 

func (m *StreamMsg) XXX_DiscardUnknown()

func (*StreamMsg) XXX_Marshal 

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

func (*StreamMsg) XXX_Merge 

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

func (*StreamMsg) XXX_Size 

func (m *StreamMsg) XXX_Size() int

func (*StreamMsg) XXX_Unmarshal 

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

type UnimplementedKipServer 

type UnimplementedKipServer struct {
}

UnimplementedKipServer can be embedded to have forward compatible implementations.

func (*UnimplementedKipServer) Attach 

func (*UnimplementedKipServer) Attach(srv Kip_AttachServer) error

func (*UnimplementedKipServer) Create 

func (*UnimplementedKipServer) Create(ctx context.Context, req *CreateRequest) (*APIReply, error)

func (*UnimplementedKipServer) Delete 

func (*UnimplementedKipServer) Delete(ctx context.Context, req *DeleteRequest) (*APIReply, error)

func (*UnimplementedKipServer) Deploy 

func (*UnimplementedKipServer) Deploy(srv Kip_DeployServer) error

func (*UnimplementedKipServer) Dump 

func (*UnimplementedKipServer) Dump(ctx context.Context, req *DumpRequest) (*APIReply, error)

func (*UnimplementedKipServer) Exec 

func (*UnimplementedKipServer) Exec(srv Kip_ExecServer) error

func (*UnimplementedKipServer) Get 

func (*UnimplementedKipServer) Get(ctx context.Context, req *GetRequest) (*APIReply, error)

func (*UnimplementedKipServer) GetLogs 

func (*UnimplementedKipServer) GetLogs(ctx context.Context, req *LogsRequest) (*APIReply, error)

func (*UnimplementedKipServer) GetVersion 

func (*UnimplementedKipServer) GetVersion(ctx context.Context, req *VersionRequest) (*VersionReply, error)

func (*UnimplementedKipServer) IsLeader 

func (*UnimplementedKipServer) IsLeader(ctx context.Context, req *IsLeaderRequest) (*IsLeaderReply, error)

func (*UnimplementedKipServer) StreamLogs 

func (*UnimplementedKipServer) StreamLogs(req *StreamLogsRequest, srv Kip_StreamLogsServer) error

func (*UnimplementedKipServer) Update 

func (*UnimplementedKipServer) Update(ctx context.Context, req *UpdateRequest) (*APIReply, error)

type UpdateRequest 

type UpdateRequest struct {
	Manifest             []byte   `protobuf:"bytes,1,opt,name=manifest,proto3" json:"manifest,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateRequest) Descriptor 

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

func (*UpdateRequest) GetManifest 

func (m *UpdateRequest) GetManifest() []byte

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) Reset 

func (m *UpdateRequest) Reset()

func (*UpdateRequest) String 

func (m *UpdateRequest) String() string

func (*UpdateRequest) XXX_DiscardUnknown 

func (m *UpdateRequest) XXX_DiscardUnknown()

func (*UpdateRequest) XXX_Marshal 

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

func (*UpdateRequest) XXX_Merge 

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

func (*UpdateRequest) XXX_Size 

func (m *UpdateRequest) XXX_Size() int

func (*UpdateRequest) XXX_Unmarshal 

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

type VersionReply 

type VersionReply struct {
	VersionInfo          []byte   `protobuf:"bytes,1,opt,name=versionInfo,proto3" json:"versionInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VersionReply) Descriptor 

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

func (*VersionReply) GetVersionInfo 

func (m *VersionReply) GetVersionInfo() []byte

func (*VersionReply) ProtoMessage 

func (*VersionReply) ProtoMessage()

func (*VersionReply) Reset 

func (m *VersionReply) Reset()

func (*VersionReply) String 

func (m *VersionReply) String() string

func (*VersionReply) XXX_DiscardUnknown 

func (m *VersionReply) XXX_DiscardUnknown()

func (*VersionReply) XXX_Marshal 

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

func (*VersionReply) XXX_Merge 

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

func (*VersionReply) XXX_Size 

func (m *VersionReply) XXX_Size() int

func (*VersionReply) XXX_Unmarshal 

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

type VersionRequest 

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

func (*VersionRequest) Descriptor 

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

func (*VersionRequest) ProtoMessage 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) Reset 

func (m *VersionRequest) Reset()

func (*VersionRequest) String 

func (m *VersionRequest) String() string

func (*VersionRequest) XXX_DiscardUnknown 

func (m *VersionRequest) XXX_DiscardUnknown()

func (*VersionRequest) XXX_Marshal 

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

func (*VersionRequest) XXX_Merge 

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

func (*VersionRequest) XXX_Size 

func (m *VersionRequest) XXX_Size() int

func (*VersionRequest) XXX_Unmarshal 

func (m *VersionRequest) XXX_Unmarshal(b []byte) 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.