apiclient

package
v2.3.0-rc4 Latest Latest
Warning

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

 Go to latest Published: Feb 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) 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.