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) GenerateManifest(ctx context.Context, req *ManifestRequest) (*ManifestResponse, error)

func (*UnimplementedConfigManagementPluginServiceServer) GetPluginConfig 

func (*UnimplementedConfigManagementPluginServiceServer) GetPluginConfig(ctx context.Context, req *ConfigRequest) (*ConfigResponse, error)

func (*UnimplementedConfigManagementPluginServiceServer) MatchRepository 

func (*UnimplementedConfigManagementPluginServiceServer) MatchRepository(ctx context.Context, req *RepositoryRequest) (*RepositoryResponse, 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.