podres

Documentation

Index

• Constants
• func ParseEndpoint(endpoint string) (string, error)
• type CleanupFunc
  • func GetClient(endpoint string) (podresourcesapi.PodResourcesListerClient, CleanupFunc, error)
  • func GetV1Client(endpoint string, connectionTimeout time.Duration, maxMsgSize int) (podresourcesapi.PodResourcesListerClient, CleanupFunc, error)
  • func WaitForReady(cli podresourcesapi.PodResourcesListerClient, cleanup CleanupFunc, err error) (podresourcesapi.PodResourcesListerClient, CleanupFunc, error)
• type MockPodResourcesListerClient
  • func NewMockPodResourcesListerClient(t interface{ ... }) *MockPodResourcesListerClient
  • func (_m *MockPodResourcesListerClient) Get(ctx context.Context, in *v1.GetPodResourcesRequest, opts ...grpc.CallOption) (*v1.GetPodResourcesResponse, error)
  • func (_m *MockPodResourcesListerClient) GetAllocatableResources(ctx context.Context, in *v1.AllocatableResourcesRequest, ...) (*v1.AllocatableResourcesResponse, error)
  • func (_m *MockPodResourcesListerClient) List(ctx context.Context, in *v1.ListPodResourcesRequest, opts ...grpc.CallOption) (*v1.ListPodResourcesResponse, error)
• type UnsupportedProtocolError
  • func (e UnsupportedProtocolError) Error() string

Constants

const (
	DefaultTimeout    = 10 * time.Second
	DefaultMaxMsgSize = 1024 * 1024 * 16 // 16 MiB

	UnixProtocol = "unix"
)

Functions

func ParseEndpoint

func ParseEndpoint(endpoint string) (string, error)

Types

type CleanupFunc

type CleanupFunc func() error

func GetClient

func GetClient(endpoint string) (podresourcesapi.PodResourcesListerClient, CleanupFunc, error)

func GetV1Client

func GetV1Client(endpoint string, connectionTimeout time.Duration, maxMsgSize int) (podresourcesapi.PodResourcesListerClient, CleanupFunc, error)

func WaitForReady

func WaitForReady(cli podresourcesapi.PodResourcesListerClient, cleanup CleanupFunc, err error) (podresourcesapi.PodResourcesListerClient, CleanupFunc, error)

type MockPodResourcesListerClient

type MockPodResourcesListerClient struct {
	mock.Mock
}

MockPodResourcesListerClient is an autogenerated mock type for the PodResourcesListerClient type

func NewMockPodResourcesListerClient

func NewMockPodResourcesListerClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockPodResourcesListerClient

NewMockPodResourcesListerClient creates a new instance of MockPodResourcesListerClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockPodResourcesListerClient) Get

func (_m *MockPodResourcesListerClient) Get(ctx context.Context, in *v1.GetPodResourcesRequest, opts ...grpc.CallOption) (*v1.GetPodResourcesResponse, error)

Get provides a mock function with given fields: ctx, in, opts

func (*MockPodResourcesListerClient) GetAllocatableResources

func (_m *MockPodResourcesListerClient) GetAllocatableResources(ctx context.Context, in *v1.AllocatableResourcesRequest, opts ...grpc.CallOption) (*v1.AllocatableResourcesResponse, error)

GetAllocatableResources provides a mock function with given fields: ctx, in, opts

func (*MockPodResourcesListerClient) List

func (_m *MockPodResourcesListerClient) List(ctx context.Context, in *v1.ListPodResourcesRequest, opts ...grpc.CallOption) (*v1.ListPodResourcesResponse, error)

List provides a mock function with given fields: ctx, in, opts

type UnsupportedProtocolError

type UnsupportedProtocolError struct {
	// contains filtered or unexported fields
}

func (UnsupportedProtocolError) Error

func (e UnsupportedProtocolError) Error() string