pb

package
v0.0.0-...-7c152a1 Latest Latest
Warning

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

 Go to latest Published: Nov 19, 2024 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Dispatch_Deployments_FullMethodName  = "/pb.Dispatch/Deployments"
	Dispatch_ReportStatus_FullMethodName = "/pb.Dispatch/ReportStatus"
)
View Source 
const (
	Deploy_Deploy_FullMethodName = "/pb.Deploy/Deploy"
	Deploy_Status_FullMethodName = "/pb.Deploy/Status"
)
View Source 
const (
	LogFieldDeliveryID           = "delivery_id"
	LogFieldCorrelationID        = "correlation_id"
	LogFieldRepository           = "repository"
	LogFieldDeploymentID         = "deployment_id"
	LogFieldCluster              = "deployment_cluster"
	LogFieldTeam                 = "team"
	LogFieldDeploymentStatusType = "deployment_status"
)

Variables

View Source 
var (
	DeploymentState_name = map[int32]string{
		0: "success",
		1: "error",
		2: "failure",
		3: "inactive",
		4: "in_progress",
		5: "queued",
		6: "pending",
	}
	DeploymentState_value = map[string]int32{
		"success":     0,
		"error":       1,
		"failure":     2,
		"inactive":    3,
		"in_progress": 4,
		"queued":      5,
		"pending":     6,
	}
)

Enum value maps for DeploymentState.

View Source 
var Deploy_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.Deploy",
	HandlerType: (*DeployServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Deploy",
			Handler:    _Deploy_Deploy_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Status",
			Handler:       _Deploy_Status_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/pb/deployment.proto",
}

Deploy_ServiceDesc is the grpc.ServiceDesc for Deploy service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Dispatch_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.Dispatch",
	HandlerType: (*DispatchServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReportStatus",
			Handler:    _Dispatch_ReportStatus_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Deployments",
			Handler:       _Dispatch_Deployments_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/pb/deployment.proto",
}

Dispatch_ServiceDesc is the grpc.ServiceDesc for Dispatch service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_pkg_pb_deployment_proto protoreflect.FileDescriptor

Functions

func RegisterDeployServer 

func RegisterDeployServer(s grpc.ServiceRegistrar, srv DeployServer)

func RegisterDispatchServer 

func RegisterDispatchServer(s grpc.ServiceRegistrar, srv DispatchServer)

func TimeAsTimestamp 

func TimeAsTimestamp(t time.Time) *timestamp.Timestamp

func TimestampAsTime 

func TimestampAsTime(timestamp *timestamp.Timestamp) time.Time

Types

type DeployClient 

type DeployClient interface {
	Deploy(ctx context.Context, in *DeploymentRequest, opts ...grpc.CallOption) (*DeploymentStatus, error)
	Status(ctx context.Context, in *DeploymentRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DeploymentStatus], error)
}

DeployClient is the client API for Deploy service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDeployClient 

func NewDeployClient(cc grpc.ClientConnInterface) DeployClient

type DeployServer 

type DeployServer interface {
	Deploy(context.Context, *DeploymentRequest) (*DeploymentStatus, error)
	Status(*DeploymentRequest, grpc.ServerStreamingServer[DeploymentStatus]) error
	// contains filtered or unexported methods
}

DeployServer is the server API for Deploy service. All implementations must embed UnimplementedDeployServer for forward compatibility.

type Deploy_StatusClient 

type Deploy_StatusClient = grpc.ServerStreamingClient[DeploymentStatus]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Deploy_StatusServer 

type Deploy_StatusServer = grpc.ServerStreamingServer[DeploymentStatus]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type DeploymentRequest 

type DeploymentRequest struct {
	ID                string                 `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Time              *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	Deadline          *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
	Cluster           string                 `protobuf:"bytes,4,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Team              string                 `protobuf:"bytes,5,opt,name=team,proto3" json:"team,omitempty"`
	GitRefSha         string                 `protobuf:"bytes,6,opt,name=gitRefSha,proto3" json:"gitRefSha,omitempty"`
	Kubernetes        *Kubernetes            `protobuf:"bytes,7,opt,name=kubernetes,proto3" json:"kubernetes,omitempty"`
	Repository        *GithubRepository      `protobuf:"bytes,8,opt,name=repository,proto3" json:"repository,omitempty"`
	GithubEnvironment string                 `protobuf:"bytes,9,opt,name=GithubEnvironment,proto3" json:"GithubEnvironment,omitempty"`
	TraceParent       string                 `protobuf:"bytes,10,opt,name=traceParent,proto3" json:"traceParent,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploymentRequest) Context 

func (x *DeploymentRequest) Context() (context.Context, context.CancelFunc)

func (*DeploymentRequest) Descriptor deprecated 

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

Deprecated: Use DeploymentRequest.ProtoReflect.Descriptor instead.

func (*DeploymentRequest) GetCluster 

func (x *DeploymentRequest) GetCluster() string

func (*DeploymentRequest) GetDeadline 

func (x *DeploymentRequest) GetDeadline() *timestamppb.Timestamp

func (*DeploymentRequest) GetGitRefSha 

func (x *DeploymentRequest) GetGitRefSha() string

func (*DeploymentRequest) GetGithubEnvironment 

func (x *DeploymentRequest) GetGithubEnvironment() string

func (*DeploymentRequest) GetID 

func (x *DeploymentRequest) GetID() string

func (*DeploymentRequest) GetKubernetes 

func (x *DeploymentRequest) GetKubernetes() *Kubernetes

func (*DeploymentRequest) GetRepository 

func (x *DeploymentRequest) GetRepository() *GithubRepository

func (*DeploymentRequest) GetTeam 

func (x *DeploymentRequest) GetTeam() string

func (*DeploymentRequest) GetTime 

func (x *DeploymentRequest) GetTime() *timestamppb.Timestamp

func (*DeploymentRequest) GetTraceParent 

func (x *DeploymentRequest) GetTraceParent() string

func (*DeploymentRequest) LogFields 

func (x *DeploymentRequest) LogFields() log.Fields

func (*DeploymentRequest) ProtoMessage 

func (*DeploymentRequest) ProtoMessage()

func (*DeploymentRequest) ProtoReflect 

func (x *DeploymentRequest) ProtoReflect() protoreflect.Message

func (*DeploymentRequest) Reset 

func (x *DeploymentRequest) Reset()

func (*DeploymentRequest) String 

func (x *DeploymentRequest) String() string

func (*DeploymentRequest) Timestamp 

func (x *DeploymentRequest) Timestamp() time.Time

type DeploymentState 

type DeploymentState int32
const (
	DeploymentState_success     DeploymentState = 0
	DeploymentState_error       DeploymentState = 1
	DeploymentState_failure     DeploymentState = 2
	DeploymentState_inactive    DeploymentState = 3
	DeploymentState_in_progress DeploymentState = 4
	DeploymentState_queued      DeploymentState = 5
	DeploymentState_pending     DeploymentState = 6
)

func (DeploymentState) Descriptor 

func (DeploymentState) Descriptor() protoreflect.EnumDescriptor

func (DeploymentState) Enum 

func (x DeploymentState) Enum() *DeploymentState

func (DeploymentState) EnumDescriptor deprecated 

func (DeploymentState) EnumDescriptor() ([]byte, []int)

Deprecated: Use DeploymentState.Descriptor instead.

func (DeploymentState) Finished 

func (x DeploymentState) Finished() bool

func (DeploymentState) IsError 

func (x DeploymentState) IsError() bool

func (DeploymentState) Number 

func (x DeploymentState) Number() protoreflect.EnumNumber

func (DeploymentState) StatusEmoji 

func (x DeploymentState) StatusEmoji() rune

func (DeploymentState) String 

func (x DeploymentState) String() string

func (DeploymentState) Type 

func (DeploymentState) Type() protoreflect.EnumType

type DeploymentStatus 

type DeploymentStatus struct {
	Request *DeploymentRequest     `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Time    *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	State   DeploymentState        `protobuf:"varint,3,opt,name=state,proto3,enum=pb.DeploymentState" json:"state,omitempty"`
	Message string                 `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func NewErrorStatus 

func NewErrorStatus(req *DeploymentRequest, err error) *DeploymentStatus

func NewFailureStatus 

func NewFailureStatus(req *DeploymentRequest, err error) *DeploymentStatus

func NewInProgressStatus 

func NewInProgressStatus(req *DeploymentRequest, format string, args ...interface{}) *DeploymentStatus

func NewInactiveStatus 

func NewInactiveStatus(req *DeploymentRequest) *DeploymentStatus

func NewQueuedStatus 

func NewQueuedStatus(req *DeploymentRequest) *DeploymentStatus

func NewSuccessStatus 

func NewSuccessStatus(req *DeploymentRequest) *DeploymentStatus

func (*DeploymentStatus) Descriptor deprecated 

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

Deprecated: Use DeploymentStatus.ProtoReflect.Descriptor instead.

func (*DeploymentStatus) GetMessage 

func (x *DeploymentStatus) GetMessage() string

func (*DeploymentStatus) GetRequest 

func (x *DeploymentStatus) GetRequest() *DeploymentRequest

func (*DeploymentStatus) GetState 

func (x *DeploymentStatus) GetState() DeploymentState

func (*DeploymentStatus) GetTime 

func (x *DeploymentStatus) GetTime() *timestamppb.Timestamp

func (*DeploymentStatus) LogFields 

func (x *DeploymentStatus) LogFields() log.Fields

func (*DeploymentStatus) ProtoMessage 

func (*DeploymentStatus) ProtoMessage()

func (*DeploymentStatus) ProtoReflect 

func (x *DeploymentStatus) ProtoReflect() protoreflect.Message

func (*DeploymentStatus) Reset 

func (x *DeploymentStatus) Reset()

func (*DeploymentStatus) String 

func (x *DeploymentStatus) String() string

func (*DeploymentStatus) Timestamp 

func (x *DeploymentStatus) Timestamp() time.Time

type DispatchClient 

type DispatchClient interface {
	Deployments(ctx context.Context, in *GetDeploymentOpts, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DeploymentRequest], error)
	ReportStatus(ctx context.Context, in *DeploymentStatus, opts ...grpc.CallOption) (*ReportStatusOpts, error)
}

DispatchClient is the client API for Dispatch service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDispatchClient 

func NewDispatchClient(cc grpc.ClientConnInterface) DispatchClient

type DispatchServer 

type DispatchServer interface {
	Deployments(*GetDeploymentOpts, grpc.ServerStreamingServer[DeploymentRequest]) error
	ReportStatus(context.Context, *DeploymentStatus) (*ReportStatusOpts, error)
	// contains filtered or unexported methods
}

DispatchServer is the server API for Dispatch service. All implementations must embed UnimplementedDispatchServer for forward compatibility.

type Dispatch_DeploymentsClient 

type Dispatch_DeploymentsClient = grpc.ServerStreamingClient[DeploymentRequest]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Dispatch_DeploymentsServer 

type Dispatch_DeploymentsServer = grpc.ServerStreamingServer[DeploymentRequest]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type GetDeploymentOpts 

type GetDeploymentOpts struct {
	Cluster     string                 `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	StartupTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=startupTime,proto3" json:"startupTime,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDeploymentOpts) Descriptor deprecated 

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

Deprecated: Use GetDeploymentOpts.ProtoReflect.Descriptor instead.

func (*GetDeploymentOpts) GetCluster 

func (x *GetDeploymentOpts) GetCluster() string

func (*GetDeploymentOpts) GetStartupTime 

func (x *GetDeploymentOpts) GetStartupTime() *timestamppb.Timestamp

func (*GetDeploymentOpts) ProtoMessage 

func (*GetDeploymentOpts) ProtoMessage()

func (*GetDeploymentOpts) ProtoReflect 

func (x *GetDeploymentOpts) ProtoReflect() protoreflect.Message

func (*GetDeploymentOpts) Reset 

func (x *GetDeploymentOpts) Reset()

func (*GetDeploymentOpts) String 

func (x *GetDeploymentOpts) String() string

type GithubRepository 

type GithubRepository struct {
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Name  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GithubRepository) Descriptor deprecated 

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

Deprecated: Use GithubRepository.ProtoReflect.Descriptor instead.

func (*GithubRepository) FullName 

func (m *GithubRepository) FullName() string

func (*GithubRepository) FullNamePtr 

func (m *GithubRepository) FullNamePtr() *string

FullNamePtr returns a pointer to the full name "navikt/foobar" of the repository. If GithubRepository is null, returns a null pointer.

func (*GithubRepository) GetName 

func (x *GithubRepository) GetName() string

func (*GithubRepository) GetOwner 

func (x *GithubRepository) GetOwner() string

func (*GithubRepository) ProtoMessage 

func (*GithubRepository) ProtoMessage()

func (*GithubRepository) ProtoReflect 

func (x *GithubRepository) ProtoReflect() protoreflect.Message

func (*GithubRepository) Reset 

func (x *GithubRepository) Reset()

func (*GithubRepository) String 

func (x *GithubRepository) String() string

func (*GithubRepository) Valid 

func (m *GithubRepository) Valid() bool

type Kubernetes 

type Kubernetes struct {
	Resources []*structpb.Struct `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func KubernetesFromJSON 

func KubernetesFromJSON(data []byte) (*Kubernetes, error)

func KubernetesFromJSONResources 

func KubernetesFromJSONResources(resources json.RawMessage) (*Kubernetes, error)

We must use the jsonpb package to unmarshal data into a []*structpb.Struct data structure. The jsonpb.Unmarshal function must unmarshal into a type that satisfies the Proto interface. This function wraps the provided raw data into a higher level data structure (Kubernetes) and returns that object instead.

func (*Kubernetes) Descriptor deprecated 

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

Deprecated: Use Kubernetes.ProtoReflect.Descriptor instead.

func (*Kubernetes) GetResources 

func (x *Kubernetes) GetResources() []*structpb.Struct

func (*Kubernetes) JSONResources 

func (m *Kubernetes) JSONResources() ([]json.RawMessage, error)

func (*Kubernetes) ProtoMessage 

func (*Kubernetes) ProtoMessage()

func (*Kubernetes) ProtoReflect 

func (x *Kubernetes) ProtoReflect() protoreflect.Message

func (*Kubernetes) Reset 

func (x *Kubernetes) Reset()

func (*Kubernetes) String 

func (x *Kubernetes) String() string

type MockDeployClient 

type MockDeployClient struct {
	mock.Mock
}

MockDeployClient is an autogenerated mock type for the DeployClient type

func NewMockDeployClient 

func NewMockDeployClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDeployClient

NewMockDeployClient creates a new instance of MockDeployClient. 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 (*MockDeployClient) Deploy 

func (_m *MockDeployClient) Deploy(ctx context.Context, in *DeploymentRequest, opts ...grpc.CallOption) (*DeploymentStatus, error)

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

func (*MockDeployClient) Status 

func (_m *MockDeployClient) Status(ctx context.Context, in *DeploymentRequest, opts ...grpc.CallOption) (Deploy_StatusClient, error)

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

type MockDeployServer 

type MockDeployServer struct {
	mock.Mock
}

MockDeployServer is an autogenerated mock type for the DeployServer type

func NewMockDeployServer 

func NewMockDeployServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDeployServer

NewMockDeployServer creates a new instance of MockDeployServer. 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 (*MockDeployServer) Deploy 

func (_m *MockDeployServer) Deploy(_a0 context.Context, _a1 *DeploymentRequest) (*DeploymentStatus, error)

Deploy provides a mock function with given fields: _a0, _a1

func (*MockDeployServer) Status 

func (_m *MockDeployServer) Status(_a0 *DeploymentRequest, _a1 Deploy_StatusServer) error

Status provides a mock function with given fields: _a0, _a1

type MockDeploy_StatusClient 

type MockDeploy_StatusClient struct {
	mock.Mock
}

MockDeploy_StatusClient is an autogenerated mock type for the Deploy_StatusClient type

func NewMockDeploy_StatusClient 

func NewMockDeploy_StatusClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDeploy_StatusClient

NewMockDeploy_StatusClient creates a new instance of MockDeploy_StatusClient. 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 (*MockDeploy_StatusClient) CloseSend 

func (_m *MockDeploy_StatusClient) CloseSend() error

CloseSend provides a mock function with given fields:

func (*MockDeploy_StatusClient) Context 

func (_m *MockDeploy_StatusClient) Context() context.Context

Context provides a mock function with given fields:

func (*MockDeploy_StatusClient) Header 

func (_m *MockDeploy_StatusClient) Header() (metadata.MD, error)

Header provides a mock function with given fields:

func (*MockDeploy_StatusClient) Recv 

func (_m *MockDeploy_StatusClient) Recv() (*DeploymentStatus, error)

Recv provides a mock function with given fields:

func (*MockDeploy_StatusClient) RecvMsg 

func (_m *MockDeploy_StatusClient) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*MockDeploy_StatusClient) SendMsg 

func (_m *MockDeploy_StatusClient) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*MockDeploy_StatusClient) Trailer 

func (_m *MockDeploy_StatusClient) Trailer() metadata.MD

Trailer provides a mock function with given fields:

type MockDeploy_StatusServer 

type MockDeploy_StatusServer struct {
	mock.Mock
}

MockDeploy_StatusServer is an autogenerated mock type for the Deploy_StatusServer type

func NewMockDeploy_StatusServer 

func NewMockDeploy_StatusServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDeploy_StatusServer

NewMockDeploy_StatusServer creates a new instance of MockDeploy_StatusServer. 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 (*MockDeploy_StatusServer) Context 

func (_m *MockDeploy_StatusServer) Context() context.Context

Context provides a mock function with given fields:

func (*MockDeploy_StatusServer) RecvMsg 

func (_m *MockDeploy_StatusServer) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*MockDeploy_StatusServer) Send 

func (_m *MockDeploy_StatusServer) Send(_a0 *DeploymentStatus) error

Send provides a mock function with given fields: _a0

func (*MockDeploy_StatusServer) SendHeader 

func (_m *MockDeploy_StatusServer) SendHeader(_a0 metadata.MD) error

SendHeader provides a mock function with given fields: _a0

func (*MockDeploy_StatusServer) SendMsg 

func (_m *MockDeploy_StatusServer) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*MockDeploy_StatusServer) SetHeader 

func (_m *MockDeploy_StatusServer) SetHeader(_a0 metadata.MD) error

SetHeader provides a mock function with given fields: _a0

func (*MockDeploy_StatusServer) SetTrailer 

func (_m *MockDeploy_StatusServer) SetTrailer(_a0 metadata.MD)

SetTrailer provides a mock function with given fields: _a0

type MockDispatchClient 

type MockDispatchClient struct {
	mock.Mock
}

MockDispatchClient is an autogenerated mock type for the DispatchClient type

func NewMockDispatchClient 

func NewMockDispatchClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDispatchClient

NewMockDispatchClient creates a new instance of MockDispatchClient. 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 (*MockDispatchClient) Deployments 

func (_m *MockDispatchClient) Deployments(ctx context.Context, in *GetDeploymentOpts, opts ...grpc.CallOption) (Dispatch_DeploymentsClient, error)

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

func (*MockDispatchClient) ReportStatus 

func (_m *MockDispatchClient) ReportStatus(ctx context.Context, in *DeploymentStatus, opts ...grpc.CallOption) (*ReportStatusOpts, error)

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

type MockDispatchServer 

type MockDispatchServer struct {
	mock.Mock
}

MockDispatchServer is an autogenerated mock type for the DispatchServer type

func NewMockDispatchServer 

func NewMockDispatchServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDispatchServer

NewMockDispatchServer creates a new instance of MockDispatchServer. 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 (*MockDispatchServer) Deployments 

func (_m *MockDispatchServer) Deployments(_a0 *GetDeploymentOpts, _a1 Dispatch_DeploymentsServer) error

Deployments provides a mock function with given fields: _a0, _a1

func (*MockDispatchServer) ReportStatus 

func (_m *MockDispatchServer) ReportStatus(_a0 context.Context, _a1 *DeploymentStatus) (*ReportStatusOpts, error)

ReportStatus provides a mock function with given fields: _a0, _a1

type MockDispatch_DeploymentsClient 

type MockDispatch_DeploymentsClient struct {
	mock.Mock
}

MockDispatch_DeploymentsClient is an autogenerated mock type for the Dispatch_DeploymentsClient type

func NewMockDispatch_DeploymentsClient 

func NewMockDispatch_DeploymentsClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDispatch_DeploymentsClient

NewMockDispatch_DeploymentsClient creates a new instance of MockDispatch_DeploymentsClient. 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 (*MockDispatch_DeploymentsClient) CloseSend 

func (_m *MockDispatch_DeploymentsClient) CloseSend() error

CloseSend provides a mock function with given fields:

func (*MockDispatch_DeploymentsClient) Context 

func (_m *MockDispatch_DeploymentsClient) Context() context.Context

Context provides a mock function with given fields:

func (*MockDispatch_DeploymentsClient) Header 

func (_m *MockDispatch_DeploymentsClient) Header() (metadata.MD, error)

Header provides a mock function with given fields:

func (*MockDispatch_DeploymentsClient) Recv 

func (_m *MockDispatch_DeploymentsClient) Recv() (*DeploymentRequest, error)

Recv provides a mock function with given fields:

func (*MockDispatch_DeploymentsClient) RecvMsg 

func (_m *MockDispatch_DeploymentsClient) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*MockDispatch_DeploymentsClient) SendMsg 

func (_m *MockDispatch_DeploymentsClient) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*MockDispatch_DeploymentsClient) Trailer 

func (_m *MockDispatch_DeploymentsClient) Trailer() metadata.MD

Trailer provides a mock function with given fields:

type MockDispatch_DeploymentsServer 

type MockDispatch_DeploymentsServer struct {
	mock.Mock
}

MockDispatch_DeploymentsServer is an autogenerated mock type for the Dispatch_DeploymentsServer type

func NewMockDispatch_DeploymentsServer 

func NewMockDispatch_DeploymentsServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDispatch_DeploymentsServer

NewMockDispatch_DeploymentsServer creates a new instance of MockDispatch_DeploymentsServer. 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 (*MockDispatch_DeploymentsServer) Context 

func (_m *MockDispatch_DeploymentsServer) Context() context.Context

Context provides a mock function with given fields:

func (*MockDispatch_DeploymentsServer) RecvMsg 

func (_m *MockDispatch_DeploymentsServer) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*MockDispatch_DeploymentsServer) Send 

func (_m *MockDispatch_DeploymentsServer) Send(_a0 *DeploymentRequest) error

Send provides a mock function with given fields: _a0

func (*MockDispatch_DeploymentsServer) SendHeader 

func (_m *MockDispatch_DeploymentsServer) SendHeader(_a0 metadata.MD) error

SendHeader provides a mock function with given fields: _a0

func (*MockDispatch_DeploymentsServer) SendMsg 

func (_m *MockDispatch_DeploymentsServer) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*MockDispatch_DeploymentsServer) SetHeader 

func (_m *MockDispatch_DeploymentsServer) SetHeader(_a0 metadata.MD) error

SetHeader provides a mock function with given fields: _a0

func (*MockDispatch_DeploymentsServer) SetTrailer 

func (_m *MockDispatch_DeploymentsServer) SetTrailer(_a0 metadata.MD)

SetTrailer provides a mock function with given fields: _a0

type MockUnsafeDeployServer 

type MockUnsafeDeployServer struct {
	mock.Mock
}

MockUnsafeDeployServer is an autogenerated mock type for the UnsafeDeployServer type

func NewMockUnsafeDeployServer 

func NewMockUnsafeDeployServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockUnsafeDeployServer

NewMockUnsafeDeployServer creates a new instance of MockUnsafeDeployServer. 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.

type MockUnsafeDispatchServer 

type MockUnsafeDispatchServer struct {
	mock.Mock
}

MockUnsafeDispatchServer is an autogenerated mock type for the UnsafeDispatchServer type

func NewMockUnsafeDispatchServer 

func NewMockUnsafeDispatchServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockUnsafeDispatchServer

NewMockUnsafeDispatchServer creates a new instance of MockUnsafeDispatchServer. 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.

type ReportStatusOpts 

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

func (*ReportStatusOpts) Descriptor deprecated 

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

Deprecated: Use ReportStatusOpts.ProtoReflect.Descriptor instead.

func (*ReportStatusOpts) ProtoMessage 

func (*ReportStatusOpts) ProtoMessage()

func (*ReportStatusOpts) ProtoReflect 

func (x *ReportStatusOpts) ProtoReflect() protoreflect.Message

func (*ReportStatusOpts) Reset 

func (x *ReportStatusOpts) Reset()

func (*ReportStatusOpts) String 

func (x *ReportStatusOpts) String() string

type UnimplementedDeployServer 

type UnimplementedDeployServer struct{}

UnimplementedDeployServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedDeployServer) Deploy 

func (UnimplementedDeployServer) Deploy(context.Context, *DeploymentRequest) (*DeploymentStatus, error)

func (UnimplementedDeployServer) Status 

func (UnimplementedDeployServer) Status(*DeploymentRequest, grpc.ServerStreamingServer[DeploymentStatus]) error

type UnimplementedDispatchServer 

type UnimplementedDispatchServer struct{}

UnimplementedDispatchServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedDispatchServer) Deployments 

func (UnimplementedDispatchServer) Deployments(*GetDeploymentOpts, grpc.ServerStreamingServer[DeploymentRequest]) error

func (UnimplementedDispatchServer) ReportStatus 

func (UnimplementedDispatchServer) ReportStatus(context.Context, *DeploymentStatus) (*ReportStatusOpts, error)

type UnsafeDeployServer 

type UnsafeDeployServer interface {
	// contains filtered or unexported methods
}

UnsafeDeployServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DeployServer will result in compilation errors.

type UnsafeDispatchServer 

type UnsafeDispatchServer interface {
	// contains filtered or unexported methods
}

UnsafeDispatchServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DispatchServer will result in compilation errors.

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.