selfs

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Jun 4, 2021 License: Apache-2.0, Apache-2.0 Imports: 14 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Version = "v1.0.0"
)

Functions

func Commands 

func Commands(getContext func() context.Context,
	getClientConn func() *grpc.ClientConn) (commands []*cobra.Command)

func Register 

func Register(s *grpc.Server)

func RegisterSelfAdminServer 

func RegisterSelfAdminServer(s *grpc.Server, srv SelfAdminServer)

Types

type RuntimeReply 

type RuntimeReply struct {
	Version              string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Executable           string   `protobuf:"bytes,2,opt,name=executable,proto3" json:"executable,omitempty"`
	Pid                  string   `protobuf:"bytes,3,opt,name=pid,proto3" json:"pid,omitempty"`
	Pwd                  string   `protobuf:"bytes,6,opt,name=pwd,proto3" json:"pwd,omitempty"`
	Args                 []string `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
	Environ              []string `protobuf:"bytes,5,rep,name=environ,proto3" json:"environ,omitempty"`
	Netrc                []string `protobuf:"bytes,7,rep,name=netrc,proto3" json:"netrc,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RuntimeReply) Descriptor 

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

func (*RuntimeReply) GetArgs 

func (m *RuntimeReply) GetArgs() []string

func (*RuntimeReply) GetEnviron 

func (m *RuntimeReply) GetEnviron() []string

func (*RuntimeReply) GetExecutable 

func (m *RuntimeReply) GetExecutable() string

func (*RuntimeReply) GetNetrc 

func (m *RuntimeReply) GetNetrc() []string

func (*RuntimeReply) GetPid 

func (m *RuntimeReply) GetPid() string

func (*RuntimeReply) GetPwd 

func (m *RuntimeReply) GetPwd() string

func (*RuntimeReply) GetVersion 

func (m *RuntimeReply) GetVersion() string

func (*RuntimeReply) ProtoMessage 

func (*RuntimeReply) ProtoMessage()

func (*RuntimeReply) Reset 

func (m *RuntimeReply) Reset()

func (*RuntimeReply) String 

func (m *RuntimeReply) String() string

func (*RuntimeReply) XXX_DiscardUnknown 

func (m *RuntimeReply) XXX_DiscardUnknown()

func (*RuntimeReply) XXX_Marshal 

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

func (*RuntimeReply) XXX_Merge 

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

func (*RuntimeReply) XXX_Size 

func (m *RuntimeReply) XXX_Size() int

func (*RuntimeReply) XXX_Unmarshal 

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

type RuntimeRequest 

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

func (*RuntimeRequest) Descriptor 

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

func (*RuntimeRequest) ProtoMessage 

func (*RuntimeRequest) ProtoMessage()

func (*RuntimeRequest) Reset 

func (m *RuntimeRequest) Reset()

func (*RuntimeRequest) String 

func (m *RuntimeRequest) String() string

func (*RuntimeRequest) XXX_DiscardUnknown 

func (m *RuntimeRequest) XXX_DiscardUnknown()

func (*RuntimeRequest) XXX_Marshal 

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

func (*RuntimeRequest) XXX_Merge 

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

func (*RuntimeRequest) XXX_Size 

func (m *RuntimeRequest) XXX_Size() int

func (*RuntimeRequest) XXX_Unmarshal 

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

type SelfAdminClient 

type SelfAdminClient interface {
	Upgrade(ctx context.Context, in *UpgradeRequest, opts ...grpc.CallOption) (*UpgradeReply, error)
	Runtime(ctx context.Context, in *RuntimeRequest, opts ...grpc.CallOption) (*RuntimeReply, error)
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetReply, error)
}

SelfAdminClient is the client API for SelfAdmin service.

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

func NewSelfAdminClient 

func NewSelfAdminClient(cc *grpc.ClientConn) SelfAdminClient

type SelfAdminServer 

type SelfAdminServer interface {
	Upgrade(context.Context, *UpgradeRequest) (*UpgradeReply, error)
	Runtime(context.Context, *RuntimeRequest) (*RuntimeReply, error)
	Set(context.Context, *SetRequest) (*SetReply, error)
}

SelfAdminServer is the server API for SelfAdmin service.

type SetReply 

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

func (*SetReply) Descriptor 

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

func (*SetReply) ProtoMessage 

func (*SetReply) ProtoMessage()

func (*SetReply) Reset 

func (m *SetReply) Reset()

func (*SetReply) String 

func (m *SetReply) String() string

func (*SetReply) XXX_DiscardUnknown 

func (m *SetReply) XXX_DiscardUnknown()

func (*SetReply) XXX_Marshal 

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

func (*SetReply) XXX_Merge 

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

func (*SetReply) XXX_Size 

func (m *SetReply) XXX_Size() int

func (*SetReply) XXX_Unmarshal 

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

type SetRequest 

type SetRequest 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetRequest) Descriptor 

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

func (*SetRequest) GetKey 

func (m *SetRequest) GetKey() string

func (*SetRequest) GetValue 

func (m *SetRequest) GetValue() string

func (*SetRequest) ProtoMessage 

func (*SetRequest) ProtoMessage()

func (*SetRequest) Reset 

func (m *SetRequest) Reset()

func (*SetRequest) String 

func (m *SetRequest) String() string

func (*SetRequest) XXX_DiscardUnknown 

func (m *SetRequest) XXX_DiscardUnknown()

func (*SetRequest) XXX_Marshal 

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

func (*SetRequest) XXX_Merge 

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

func (*SetRequest) XXX_Size 

func (m *SetRequest) XXX_Size() int

func (*SetRequest) XXX_Unmarshal 

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

type SetType 

type SetType int
const (
	Env SetType = iota
	Netrc
	Unknown
)

func KeyClassify 

func KeyClassify(key string) SetType

type UnimplementedSelfAdminServer 

type UnimplementedSelfAdminServer struct {
}

UnimplementedSelfAdminServer can be embedded to have forward compatible implementations.

func (*UnimplementedSelfAdminServer) Runtime 

func (*UnimplementedSelfAdminServer) Runtime(ctx context.Context, req *RuntimeRequest) (*RuntimeReply, error)

func (*UnimplementedSelfAdminServer) Set 

func (*UnimplementedSelfAdminServer) Set(ctx context.Context, req *SetRequest) (*SetReply, error)

func (*UnimplementedSelfAdminServer) Upgrade 

func (*UnimplementedSelfAdminServer) Upgrade(ctx context.Context, req *UpgradeRequest) (*UpgradeReply, error)

type UpgradeReply 

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

func (*UpgradeReply) Descriptor 

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

func (*UpgradeReply) ProtoMessage 

func (*UpgradeReply) ProtoMessage()

func (*UpgradeReply) Reset 

func (m *UpgradeReply) Reset()

func (*UpgradeReply) String 

func (m *UpgradeReply) String() string

func (*UpgradeReply) XXX_DiscardUnknown 

func (m *UpgradeReply) XXX_DiscardUnknown()

func (*UpgradeReply) XXX_Marshal 

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

func (*UpgradeReply) XXX_Merge 

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

func (*UpgradeReply) XXX_Size 

func (m *UpgradeReply) XXX_Size() int

func (*UpgradeReply) XXX_Unmarshal 

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

type UpgradeRequest 

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

func (*UpgradeRequest) Descriptor 

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

func (*UpgradeRequest) GetVersion 

func (m *UpgradeRequest) GetVersion() string

func (*UpgradeRequest) ProtoMessage 

func (*UpgradeRequest) ProtoMessage()

func (*UpgradeRequest) Reset 

func (m *UpgradeRequest) Reset()

func (*UpgradeRequest) String 

func (m *UpgradeRequest) String() string

func (*UpgradeRequest) XXX_DiscardUnknown 

func (m *UpgradeRequest) XXX_DiscardUnknown()

func (*UpgradeRequest) XXX_Marshal 

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

func (*UpgradeRequest) XXX_Merge 

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

func (*UpgradeRequest) XXX_Size 

func (m *UpgradeRequest) XXX_Size() int

func (*UpgradeRequest) XXX_Unmarshal 

func (m *UpgradeRequest) 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.