apiclient

package
v2.3.8 Latest Latest
Warning

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

Go to latest
Published: Oct 3, 2022 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) (*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) Clientset

NewConfigManagementPluginClientSet 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