apiclient

package
v2.2.0 Latest Latest
Warning

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

Go to latest
Published: Dec 14, 2021 License: Apache-2.0 Imports: 16 Imported by: 5

Documentation

Index

Constants

View Source
const (
	// MaxGRPCMessageSize contains max grpc message size
	MaxGRPCMessageSize = 100 * 1024 * 1024
)

Variables

View Source
var (
	ErrInvalidLengthPlugin        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPlugin          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPlugin = fmt.Errorf("proto: unexpected end of group")
)

Functions

func NewConnection

func NewConnection(address string, timeoutSeconds int) (*grpc.ClientConn, error)

func RegisterConfigManagementPluginServiceServer

func RegisterConfigManagementPluginServiceServer(s *grpc.Server, srv ConfigManagementPluginServiceServer)

Types

type Clientset

type Clientset interface {
	NewConfigManagementPluginClient() (io.Closer, ConfigManagementPluginServiceClient, error)
}

Clientset represents config management plugin server api clients

func NewConfigManagementPluginClientSet

func NewConfigManagementPluginClientSet(address string, timeoutSeconds int) Clientset

NewCMPServerClientset creates new instance of config management plugin server Clientset

type ConfigManagementPluginServiceClient

type ConfigManagementPluginServiceClient interface {
	// GenerateManifest generates manifest for application in specified repo name and revision
	GenerateManifest(ctx context.Context, in *ManifestRequest, opts ...grpc.CallOption) (*ManifestResponse, error)
	// MatchRepository returns whether or not the given path is supported by the plugin
	MatchRepository(ctx context.Context, in *RepositoryRequest, opts ...grpc.CallOption) (*RepositoryResponse, error)
	// Get configuration of the plugin
	GetPluginConfig(ctx context.Context, in *ConfigRequest, opts ...grpc.CallOption) (*ConfigResponse, error)
}

ConfigManagementPluginServiceClient is the client API for ConfigManagementPluginService service.

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

func NewConfigManagementPluginServiceClient

func NewConfigManagementPluginServiceClient(cc *grpc.ClientConn) ConfigManagementPluginServiceClient

type ConfigManagementPluginServiceServer

type ConfigManagementPluginServiceServer interface {
	// GenerateManifest generates manifest for application in specified repo name and revision
	GenerateManifest(context.Context, *ManifestRequest) (*ManifestResponse, error)
	// MatchRepository returns whether or not the given path is supported by the plugin
	MatchRepository(context.Context, *RepositoryRequest) (*RepositoryResponse, error)
	// Get configuration of the plugin
	GetPluginConfig(context.Context, *ConfigRequest) (*ConfigResponse, error)
}

ConfigManagementPluginServiceServer is the server API for ConfigManagementPluginService service.

type ConfigRequest

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

func (*ConfigRequest) Descriptor

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

func (*ConfigRequest) Marshal

func (m *ConfigRequest) Marshal() (dAtA []byte, err error)

func (*ConfigRequest) MarshalTo

func (m *ConfigRequest) MarshalTo(dAtA []byte) (int, error)

func (*ConfigRequest) MarshalToSizedBuffer

func (m *ConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConfigRequest) ProtoMessage

func (*ConfigRequest) ProtoMessage()

func (*ConfigRequest) Reset

func (m *ConfigRequest) Reset()

func (*ConfigRequest) Size

func (m *ConfigRequest) Size() (n int)

func (*ConfigRequest) String

func (m *ConfigRequest) String() string

func (*ConfigRequest) Unmarshal

func (m *ConfigRequest) Unmarshal(dAtA []byte) error

func (*ConfigRequest) XXX_DiscardUnknown

func (m *ConfigRequest) XXX_DiscardUnknown()

func (*ConfigRequest) XXX_Marshal

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

func (*ConfigRequest) XXX_Merge

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

func (*ConfigRequest) XXX_Size

func (m *ConfigRequest) XXX_Size() int

func (*ConfigRequest) XXX_Unmarshal

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

type ConfigResponse

type ConfigResponse struct {
	AllowConcurrency     bool     `protobuf:"varint,1,opt,name=allowConcurrency,proto3" json:"allowConcurrency,omitempty"`
	LockRepo             bool     `protobuf:"varint,2,opt,name=lockRepo,proto3" json:"lockRepo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConfigResponse) Descriptor

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

func (*ConfigResponse) GetAllowConcurrency

func (m *ConfigResponse) GetAllowConcurrency() bool

func (*ConfigResponse) GetLockRepo

func (m *ConfigResponse) GetLockRepo() bool

func (*ConfigResponse) Marshal

func (m *ConfigResponse) Marshal() (dAtA []byte, err error)

func (*ConfigResponse) MarshalTo

func (m *ConfigResponse) MarshalTo(dAtA []byte) (int, error)

func (*ConfigResponse) MarshalToSizedBuffer

func (m *ConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConfigResponse) ProtoMessage

func (*ConfigResponse) ProtoMessage()

func (*ConfigResponse) Reset

func (m *ConfigResponse) Reset()

func (*ConfigResponse) Size

func (m *ConfigResponse) Size() (n int)

func (*ConfigResponse) String

func (m *ConfigResponse) String() string

func (*ConfigResponse) Unmarshal

func (m *ConfigResponse) Unmarshal(dAtA []byte) error

func (*ConfigResponse) XXX_DiscardUnknown

func (m *ConfigResponse) XXX_DiscardUnknown()

func (*ConfigResponse) XXX_Marshal

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

func (*ConfigResponse) XXX_Merge

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

func (*ConfigResponse) XXX_Size

func (m *ConfigResponse) XXX_Size() int

func (*ConfigResponse) XXX_Unmarshal

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

type EnvEntry

type EnvEntry struct {
	// Name is the name of the variable, usually expressed in uppercase
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Value is the value of the variable
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

EnvEntry represents an entry in the application's environment

func (*EnvEntry) Descriptor

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

func (*EnvEntry) GetName

func (m *EnvEntry) GetName() string

func (*EnvEntry) GetValue

func (m *EnvEntry) GetValue() string

func (*EnvEntry) Marshal

func (m *EnvEntry) Marshal() (dAtA []byte, err error)

func (*EnvEntry) MarshalTo

func (m *EnvEntry) MarshalTo(dAtA []byte) (int, error)

func (*EnvEntry) MarshalToSizedBuffer

func (m *EnvEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EnvEntry) ProtoMessage

func (*EnvEntry) ProtoMessage()

func (*EnvEntry) Reset

func (m *EnvEntry) Reset()

func (*EnvEntry) Size

func (m *EnvEntry) Size() (n int)

func (*EnvEntry) String

func (m *EnvEntry) String() string

func (*EnvEntry) Unmarshal

func (m *EnvEntry) Unmarshal(dAtA []byte) error

func (*EnvEntry) XXX_DiscardUnknown

func (m *EnvEntry) XXX_DiscardUnknown()

func (*EnvEntry) XXX_Marshal

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

func (*EnvEntry) XXX_Merge

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

func (*EnvEntry) XXX_Size

func (m *EnvEntry) XXX_Size() int

func (*EnvEntry) XXX_Unmarshal

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

type ManifestRequest

type ManifestRequest struct {
	// Name of the application for which the request is triggered
	AppName              string      `protobuf:"bytes,1,opt,name=appName,proto3" json:"appName,omitempty"`
	AppPath              string      `protobuf:"bytes,2,opt,name=appPath,proto3" json:"appPath,omitempty"`
	RepoPath             string      `protobuf:"bytes,3,opt,name=repoPath,proto3" json:"repoPath,omitempty"`
	NoCache              bool        `protobuf:"varint,4,opt,name=noCache,proto3" json:"noCache,omitempty"`
	Env                  []*EnvEntry `protobuf:"bytes,5,rep,name=env,proto3" json:"env,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

ManifestRequest is a query for manifest generation.

func (*ManifestRequest) Descriptor

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

func (*ManifestRequest) GetAppName

func (m *ManifestRequest) GetAppName() string

func (*ManifestRequest) GetAppPath

func (m *ManifestRequest) GetAppPath() string

func (*ManifestRequest) GetEnv

func (m *ManifestRequest) GetEnv() []*EnvEntry

func (*ManifestRequest) GetNoCache

func (m *ManifestRequest) GetNoCache() bool

func (*ManifestRequest) GetRepoPath

func (m *ManifestRequest) GetRepoPath() string

func (*ManifestRequest) Marshal

func (m *ManifestRequest) Marshal() (dAtA []byte, err error)

func (*ManifestRequest) MarshalTo

func (m *ManifestRequest) MarshalTo(dAtA []byte) (int, error)

func (*ManifestRequest) MarshalToSizedBuffer

func (m *ManifestRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ManifestRequest) ProtoMessage

func (*ManifestRequest) ProtoMessage()

func (*ManifestRequest) Reset

func (m *ManifestRequest) Reset()

func (*ManifestRequest) Size

func (m *ManifestRequest) Size() (n int)

func (*ManifestRequest) String

func (m *ManifestRequest) String() string

func (*ManifestRequest) Unmarshal

func (m *ManifestRequest) Unmarshal(dAtA []byte) error

func (*ManifestRequest) XXX_DiscardUnknown

func (m *ManifestRequest) XXX_DiscardUnknown()

func (*ManifestRequest) XXX_Marshal

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

func (*ManifestRequest) XXX_Merge

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

func (*ManifestRequest) XXX_Size

func (m *ManifestRequest) XXX_Size() int

func (*ManifestRequest) XXX_Unmarshal

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

type ManifestResponse

type ManifestResponse struct {
	Manifests            []string `protobuf:"bytes,1,rep,name=manifests,proto3" json:"manifests,omitempty"`
	SourceType           string   `protobuf:"bytes,2,opt,name=sourceType,proto3" json:"sourceType,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ManifestResponse) Descriptor

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

func (*ManifestResponse) GetManifests

func (m *ManifestResponse) GetManifests() []string

func (*ManifestResponse) GetSourceType

func (m *ManifestResponse) GetSourceType() string

func (*ManifestResponse) Marshal

func (m *ManifestResponse) Marshal() (dAtA []byte, err error)

func (*ManifestResponse) MarshalTo

func (m *ManifestResponse) MarshalTo(dAtA []byte) (int, error)

func (*ManifestResponse) MarshalToSizedBuffer

func (m *ManifestResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ManifestResponse) ProtoMessage

func (*ManifestResponse) ProtoMessage()

func (*ManifestResponse) Reset

func (m *ManifestResponse) Reset()

func (*ManifestResponse) Size

func (m *ManifestResponse) Size() (n int)

func (*ManifestResponse) String

func (m *ManifestResponse) String() string

func (*ManifestResponse) Unmarshal

func (m *ManifestResponse) Unmarshal(dAtA []byte) error

func (*ManifestResponse) XXX_DiscardUnknown

func (m *ManifestResponse) XXX_DiscardUnknown()

func (*ManifestResponse) XXX_Marshal

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

func (*ManifestResponse) XXX_Merge

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

func (*ManifestResponse) XXX_Size

func (m *ManifestResponse) XXX_Size() int

func (*ManifestResponse) XXX_Unmarshal

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

type RepositoryRequest

type RepositoryRequest struct {
	Path                 string      `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Env                  []*EnvEntry `protobuf:"bytes,2,rep,name=env,proto3" json:"env,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*RepositoryRequest) Descriptor

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

func (*RepositoryRequest) GetEnv

func (m *RepositoryRequest) GetEnv() []*EnvEntry

func (*RepositoryRequest) GetPath

func (m *RepositoryRequest) GetPath() string

func (*RepositoryRequest) Marshal

func (m *RepositoryRequest) Marshal() (dAtA []byte, err error)

func (*RepositoryRequest) MarshalTo

func (m *RepositoryRequest) MarshalTo(dAtA []byte) (int, error)

func (*RepositoryRequest) MarshalToSizedBuffer

func (m *RepositoryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RepositoryRequest) ProtoMessage

func (*RepositoryRequest) ProtoMessage()

func (*RepositoryRequest) Reset

func (m *RepositoryRequest) Reset()

func (*RepositoryRequest) Size

func (m *RepositoryRequest) Size() (n int)

func (*RepositoryRequest) String

func (m *RepositoryRequest) String() string

func (*RepositoryRequest) Unmarshal

func (m *RepositoryRequest) Unmarshal(dAtA []byte) error

func (*RepositoryRequest) XXX_DiscardUnknown

func (m *RepositoryRequest) XXX_DiscardUnknown()

func (*RepositoryRequest) XXX_Marshal

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

func (*RepositoryRequest) XXX_Merge

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

func (*RepositoryRequest) XXX_Size

func (m *RepositoryRequest) XXX_Size() int

func (*RepositoryRequest) XXX_Unmarshal

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

type RepositoryResponse

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

func (*RepositoryResponse) Descriptor

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

func (*RepositoryResponse) GetIsSupported

func (m *RepositoryResponse) GetIsSupported() bool

func (*RepositoryResponse) Marshal

func (m *RepositoryResponse) Marshal() (dAtA []byte, err error)

func (*RepositoryResponse) MarshalTo

func (m *RepositoryResponse) MarshalTo(dAtA []byte) (int, error)

func (*RepositoryResponse) MarshalToSizedBuffer

func (m *RepositoryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RepositoryResponse) ProtoMessage

func (*RepositoryResponse) ProtoMessage()

func (*RepositoryResponse) Reset

func (m *RepositoryResponse) Reset()

func (*RepositoryResponse) Size

func (m *RepositoryResponse) Size() (n int)

func (*RepositoryResponse) String

func (m *RepositoryResponse) String() string

func (*RepositoryResponse) Unmarshal

func (m *RepositoryResponse) Unmarshal(dAtA []byte) error

func (*RepositoryResponse) XXX_DiscardUnknown

func (m *RepositoryResponse) XXX_DiscardUnknown()

func (*RepositoryResponse) XXX_Marshal

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

func (*RepositoryResponse) XXX_Merge

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

func (*RepositoryResponse) XXX_Size

func (m *RepositoryResponse) XXX_Size() int

func (*RepositoryResponse) XXX_Unmarshal

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

type UnimplementedConfigManagementPluginServiceServer

type UnimplementedConfigManagementPluginServiceServer struct {
}

UnimplementedConfigManagementPluginServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedConfigManagementPluginServiceServer) GenerateManifest

func (*UnimplementedConfigManagementPluginServiceServer) GetPluginConfig

func (*UnimplementedConfigManagementPluginServiceServer) MatchRepository

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL