proto

package
v3.0.0-...-181f513 Latest Latest
Warning

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

 Go to latest Published: Jan 27, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Crow_Version_FullMethodName         = "/proto.Crow/Version"
	Crow_Next_FullMethodName            = "/proto.Crow/Next"
	Crow_Init_FullMethodName            = "/proto.Crow/Init"
	Crow_Wait_FullMethodName            = "/proto.Crow/Wait"
	Crow_Done_FullMethodName            = "/proto.Crow/Done"
	Crow_Extend_FullMethodName          = "/proto.Crow/Extend"
	Crow_Update_FullMethodName          = "/proto.Crow/Update"
	Crow_Log_FullMethodName             = "/proto.Crow/Log"
	Crow_RegisterAgent_FullMethodName   = "/proto.Crow/RegisterAgent"
	Crow_UnregisterAgent_FullMethodName = "/proto.Crow/UnregisterAgent"
	Crow_ReportHealth_FullMethodName    = "/proto.Crow/ReportHealth"
)
View Source 
const (
	CrowAuth_Auth_FullMethodName = "/proto.CrowAuth/Auth"
)
View Source 
const Version int32 = 13

Version is the version of the crow.proto file, IMPORTANT: increased by 1 each time it get changed.

Variables

View Source 
var CrowAuth_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.CrowAuth",
	HandlerType: (*CrowAuthServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Auth",
			Handler:    _CrowAuth_Auth_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "crow.proto",
}

CrowAuth_ServiceDesc is the grpc.ServiceDesc for CrowAuth 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 Crow_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Crow",
	HandlerType: (*CrowServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Version",
			Handler:    _Crow_Version_Handler,
		},
		{
			MethodName: "Next",
			Handler:    _Crow_Next_Handler,
		},
		{
			MethodName: "Init",
			Handler:    _Crow_Init_Handler,
		},
		{
			MethodName: "Wait",
			Handler:    _Crow_Wait_Handler,
		},
		{
			MethodName: "Done",
			Handler:    _Crow_Done_Handler,
		},
		{
			MethodName: "Extend",
			Handler:    _Crow_Extend_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _Crow_Update_Handler,
		},
		{
			MethodName: "Log",
			Handler:    _Crow_Log_Handler,
		},
		{
			MethodName: "RegisterAgent",
			Handler:    _Crow_RegisterAgent_Handler,
		},
		{
			MethodName: "UnregisterAgent",
			Handler:    _Crow_UnregisterAgent_Handler,
		},
		{
			MethodName: "ReportHealth",
			Handler:    _Crow_ReportHealth_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "crow.proto",
}

Crow_ServiceDesc is the grpc.ServiceDesc for Crow 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_crow_proto protoreflect.FileDescriptor

Functions

func RegisterCrowAuthServer 

func RegisterCrowAuthServer(s grpc.ServiceRegistrar, srv CrowAuthServer)

func RegisterCrowServer 

func RegisterCrowServer(s grpc.ServiceRegistrar, srv CrowServer)

Types

type AgentInfo 

type AgentInfo struct {
	Platform     string            `protobuf:"bytes,1,opt,name=platform,proto3" json:"platform,omitempty"`
	Capacity     int32             `protobuf:"varint,2,opt,name=capacity,proto3" json:"capacity,omitempty"`
	Backend      string            `protobuf:"bytes,3,opt,name=backend,proto3" json:"backend,omitempty"`
	Version      string            `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	CustomLabels map[string]string `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AgentInfo) Descriptor deprecated 

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

Deprecated: Use AgentInfo.ProtoReflect.Descriptor instead.

func (*AgentInfo) GetBackend 

func (x *AgentInfo) GetBackend() string

func (*AgentInfo) GetCapacity 

func (x *AgentInfo) GetCapacity() int32

func (*AgentInfo) GetCustomLabels 

func (x *AgentInfo) GetCustomLabels() map[string]string

func (*AgentInfo) GetPlatform 

func (x *AgentInfo) GetPlatform() string

func (*AgentInfo) GetVersion 

func (x *AgentInfo) GetVersion() string

func (*AgentInfo) ProtoMessage 

func (*AgentInfo) ProtoMessage()

func (*AgentInfo) ProtoReflect 

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

func (*AgentInfo) Reset 

func (x *AgentInfo) Reset()

func (*AgentInfo) String 

func (x *AgentInfo) String() string

type AuthRequest 

type AuthRequest struct {
	AgentToken string `protobuf:"bytes,1,opt,name=agent_token,json=agentToken,proto3" json:"agent_token,omitempty"`
	AgentId    int64  `protobuf:"varint,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthRequest) Descriptor deprecated 

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

Deprecated: Use AuthRequest.ProtoReflect.Descriptor instead.

func (*AuthRequest) GetAgentId 

func (x *AuthRequest) GetAgentId() int64

func (*AuthRequest) GetAgentToken 

func (x *AuthRequest) GetAgentToken() string

func (*AuthRequest) ProtoMessage 

func (*AuthRequest) ProtoMessage()

func (*AuthRequest) ProtoReflect 

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

func (*AuthRequest) Reset 

func (x *AuthRequest) Reset()

func (*AuthRequest) String 

func (x *AuthRequest) String() string

type AuthResponse 

type AuthResponse struct {
	Status      string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	AgentId     int64  `protobuf:"varint,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	AccessToken string `protobuf:"bytes,3,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthResponse) Descriptor deprecated 

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

Deprecated: Use AuthResponse.ProtoReflect.Descriptor instead.

func (*AuthResponse) GetAccessToken 

func (x *AuthResponse) GetAccessToken() string

func (*AuthResponse) GetAgentId 

func (x *AuthResponse) GetAgentId() int64

func (*AuthResponse) GetStatus 

func (x *AuthResponse) GetStatus() string

func (*AuthResponse) ProtoMessage 

func (*AuthResponse) ProtoMessage()

func (*AuthResponse) ProtoReflect 

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

func (*AuthResponse) Reset 

func (x *AuthResponse) Reset()

func (*AuthResponse) String 

func (x *AuthResponse) String() string

type CrowAuthClient 

type CrowAuthClient interface {
	Auth(ctx context.Context, in *AuthRequest, opts ...grpc.CallOption) (*AuthResponse, error)
}

CrowAuthClient is the client API for CrowAuth 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 NewCrowAuthClient 

func NewCrowAuthClient(cc grpc.ClientConnInterface) CrowAuthClient

type CrowAuthServer 

type CrowAuthServer interface {
	Auth(context.Context, *AuthRequest) (*AuthResponse, error)
	// contains filtered or unexported methods
}

CrowAuthServer is the server API for CrowAuth service. All implementations must embed UnimplementedCrowAuthServer for forward compatibility

type CrowClient 

type CrowClient interface {
	Version(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*VersionResponse, error)
	Next(ctx context.Context, in *NextRequest, opts ...grpc.CallOption) (*NextResponse, error)
	Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*Empty, error)
	Wait(ctx context.Context, in *WaitRequest, opts ...grpc.CallOption) (*Empty, error)
	Done(ctx context.Context, in *DoneRequest, opts ...grpc.CallOption) (*Empty, error)
	Extend(ctx context.Context, in *ExtendRequest, opts ...grpc.CallOption) (*Empty, error)
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*Empty, error)
	Log(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (*Empty, error)
	RegisterAgent(ctx context.Context, in *RegisterAgentRequest, opts ...grpc.CallOption) (*RegisterAgentResponse, error)
	UnregisterAgent(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	ReportHealth(ctx context.Context, in *ReportHealthRequest, opts ...grpc.CallOption) (*Empty, error)
}

CrowClient is the client API for Crow 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 NewCrowClient 

func NewCrowClient(cc grpc.ClientConnInterface) CrowClient

type CrowServer 

type CrowServer interface {
	Version(context.Context, *Empty) (*VersionResponse, error)
	Next(context.Context, *NextRequest) (*NextResponse, error)
	Init(context.Context, *InitRequest) (*Empty, error)
	Wait(context.Context, *WaitRequest) (*Empty, error)
	Done(context.Context, *DoneRequest) (*Empty, error)
	Extend(context.Context, *ExtendRequest) (*Empty, error)
	Update(context.Context, *UpdateRequest) (*Empty, error)
	Log(context.Context, *LogRequest) (*Empty, error)
	RegisterAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error)
	UnregisterAgent(context.Context, *Empty) (*Empty, error)
	ReportHealth(context.Context, *ReportHealthRequest) (*Empty, error)
	// contains filtered or unexported methods
}

CrowServer is the server API for Crow service. All implementations must embed UnimplementedCrowServer for forward compatibility

type DoneRequest 

type DoneRequest struct {
	Id    string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State *WorkflowState `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*DoneRequest) Descriptor deprecated 

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

Deprecated: Use DoneRequest.ProtoReflect.Descriptor instead.

func (*DoneRequest) GetId 

func (x *DoneRequest) GetId() string

func (*DoneRequest) GetState 

func (x *DoneRequest) GetState() *WorkflowState

func (*DoneRequest) ProtoMessage 

func (*DoneRequest) ProtoMessage()

func (*DoneRequest) ProtoReflect 

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

func (*DoneRequest) Reset 

func (x *DoneRequest) Reset()

func (*DoneRequest) String 

func (x *DoneRequest) String() string

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type ExtendRequest 

type ExtendRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendRequest) Descriptor deprecated 

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

Deprecated: Use ExtendRequest.ProtoReflect.Descriptor instead.

func (*ExtendRequest) GetId 

func (x *ExtendRequest) GetId() string

func (*ExtendRequest) ProtoMessage 

func (*ExtendRequest) ProtoMessage()

func (*ExtendRequest) ProtoReflect 

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

func (*ExtendRequest) Reset 

func (x *ExtendRequest) Reset()

func (*ExtendRequest) String 

func (x *ExtendRequest) String() string

type Filter 

type Filter struct {
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Filter) Descriptor deprecated 

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetLabels 

func (x *Filter) GetLabels() map[string]string

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

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

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

type InitRequest 

type InitRequest struct {
	Id    string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State *WorkflowState `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*InitRequest) Descriptor deprecated 

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

Deprecated: Use InitRequest.ProtoReflect.Descriptor instead.

func (*InitRequest) GetId 

func (x *InitRequest) GetId() string

func (*InitRequest) GetState 

func (x *InitRequest) GetState() *WorkflowState

func (*InitRequest) ProtoMessage 

func (*InitRequest) ProtoMessage()

func (*InitRequest) ProtoReflect 

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

func (*InitRequest) Reset 

func (x *InitRequest) Reset()

func (*InitRequest) String 

func (x *InitRequest) String() string

type LogEntry 

type LogEntry struct {
	StepUuid string `protobuf:"bytes,1,opt,name=step_uuid,json=stepUuid,proto3" json:"step_uuid,omitempty"`
	Time     int64  `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	Line     int32  `protobuf:"varint,3,opt,name=line,proto3" json:"line,omitempty"`
	Type     int32  `protobuf:"varint,4,opt,name=type,proto3" json:"type,omitempty"` // 0 = stdout, 1 = stderr, 2 = exit-code, 3 = metadata, 4 = progress
	Data     []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntry) Descriptor deprecated 

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

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetData 

func (x *LogEntry) GetData() []byte

func (*LogEntry) GetLine 

func (x *LogEntry) GetLine() int32

func (*LogEntry) GetStepUuid 

func (x *LogEntry) GetStepUuid() string

func (*LogEntry) GetTime 

func (x *LogEntry) GetTime() int64

func (*LogEntry) GetType 

func (x *LogEntry) GetType() int32

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect 

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

func (*LogEntry) Reset 

func (x *LogEntry) Reset()

func (*LogEntry) String 

func (x *LogEntry) String() string

type LogRequest 

type LogRequest struct {
	LogEntries []*LogEntry `protobuf:"bytes,1,rep,name=logEntries,proto3" json:"logEntries,omitempty"`
	// contains filtered or unexported fields
}

func (*LogRequest) Descriptor deprecated 

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

Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.

func (*LogRequest) GetLogEntries 

func (x *LogRequest) GetLogEntries() []*LogEntry

func (*LogRequest) ProtoMessage 

func (*LogRequest) ProtoMessage()

func (*LogRequest) ProtoReflect 

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

func (*LogRequest) Reset 

func (x *LogRequest) Reset()

func (*LogRequest) String 

func (x *LogRequest) String() string

type NextRequest 

type NextRequest struct {
	Filter *Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*NextRequest) Descriptor deprecated 

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

Deprecated: Use NextRequest.ProtoReflect.Descriptor instead.

func (*NextRequest) GetFilter 

func (x *NextRequest) GetFilter() *Filter

func (*NextRequest) ProtoMessage 

func (*NextRequest) ProtoMessage()

func (*NextRequest) ProtoReflect 

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

func (*NextRequest) Reset 

func (x *NextRequest) Reset()

func (*NextRequest) String 

func (x *NextRequest) String() string

type NextResponse 

type NextResponse struct {
	Workflow *Workflow `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// contains filtered or unexported fields
}

func (*NextResponse) Descriptor deprecated 

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

Deprecated: Use NextResponse.ProtoReflect.Descriptor instead.

func (*NextResponse) GetWorkflow 

func (x *NextResponse) GetWorkflow() *Workflow

func (*NextResponse) ProtoMessage 

func (*NextResponse) ProtoMessage()

func (*NextResponse) ProtoReflect 

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

func (*NextResponse) Reset 

func (x *NextResponse) Reset()

func (*NextResponse) String 

func (x *NextResponse) String() string

type RegisterAgentRequest 

type RegisterAgentRequest struct {
	Info *AgentInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterAgentRequest) Descriptor deprecated 

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

Deprecated: Use RegisterAgentRequest.ProtoReflect.Descriptor instead.

func (*RegisterAgentRequest) GetInfo 

func (x *RegisterAgentRequest) GetInfo() *AgentInfo

func (*RegisterAgentRequest) ProtoMessage 

func (*RegisterAgentRequest) ProtoMessage()

func (*RegisterAgentRequest) ProtoReflect 

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

func (*RegisterAgentRequest) Reset 

func (x *RegisterAgentRequest) Reset()

func (*RegisterAgentRequest) String 

func (x *RegisterAgentRequest) String() string

type RegisterAgentResponse 

type RegisterAgentResponse struct {
	AgentId int64 `protobuf:"varint,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterAgentResponse) Descriptor deprecated 

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

Deprecated: Use RegisterAgentResponse.ProtoReflect.Descriptor instead.

func (*RegisterAgentResponse) GetAgentId 

func (x *RegisterAgentResponse) GetAgentId() int64

func (*RegisterAgentResponse) ProtoMessage 

func (*RegisterAgentResponse) ProtoMessage()

func (*RegisterAgentResponse) ProtoReflect 

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

func (*RegisterAgentResponse) Reset 

func (x *RegisterAgentResponse) Reset()

func (*RegisterAgentResponse) String 

func (x *RegisterAgentResponse) String() string

type ReportHealthRequest 

type ReportHealthRequest struct {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportHealthRequest) Descriptor deprecated 

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

Deprecated: Use ReportHealthRequest.ProtoReflect.Descriptor instead.

func (*ReportHealthRequest) GetStatus 

func (x *ReportHealthRequest) GetStatus() string

func (*ReportHealthRequest) ProtoMessage 

func (*ReportHealthRequest) ProtoMessage()

func (*ReportHealthRequest) ProtoReflect 

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

func (*ReportHealthRequest) Reset 

func (x *ReportHealthRequest) Reset()

func (*ReportHealthRequest) String 

func (x *ReportHealthRequest) String() string

type StepState 

type StepState struct {
	StepUuid string `protobuf:"bytes,1,opt,name=step_uuid,json=stepUuid,proto3" json:"step_uuid,omitempty"`
	Started  int64  `protobuf:"varint,2,opt,name=started,proto3" json:"started,omitempty"`
	Finished int64  `protobuf:"varint,3,opt,name=finished,proto3" json:"finished,omitempty"`
	Exited   bool   `protobuf:"varint,4,opt,name=exited,proto3" json:"exited,omitempty"`
	ExitCode int32  `protobuf:"varint,5,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Error    string `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*StepState) Descriptor deprecated 

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

Deprecated: Use StepState.ProtoReflect.Descriptor instead.

func (*StepState) GetError 

func (x *StepState) GetError() string

func (*StepState) GetExitCode 

func (x *StepState) GetExitCode() int32

func (*StepState) GetExited 

func (x *StepState) GetExited() bool

func (*StepState) GetFinished 

func (x *StepState) GetFinished() int64

func (*StepState) GetStarted 

func (x *StepState) GetStarted() int64

func (*StepState) GetStepUuid 

func (x *StepState) GetStepUuid() string

func (*StepState) ProtoMessage 

func (*StepState) ProtoMessage()

func (*StepState) ProtoReflect 

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

func (*StepState) Reset 

func (x *StepState) Reset()

func (*StepState) String 

func (x *StepState) String() string

type UnimplementedCrowAuthServer 

type UnimplementedCrowAuthServer struct {
}

UnimplementedCrowAuthServer must be embedded to have forward compatible implementations.

func (UnimplementedCrowAuthServer) Auth 

func (UnimplementedCrowAuthServer) Auth(context.Context, *AuthRequest) (*AuthResponse, error)

type UnimplementedCrowServer 

type UnimplementedCrowServer struct {
}

UnimplementedCrowServer must be embedded to have forward compatible implementations.

func (UnimplementedCrowServer) Done 

func (UnimplementedCrowServer) Done(context.Context, *DoneRequest) (*Empty, error)

func (UnimplementedCrowServer) Extend 

func (UnimplementedCrowServer) Extend(context.Context, *ExtendRequest) (*Empty, error)

func (UnimplementedCrowServer) Init 

func (UnimplementedCrowServer) Init(context.Context, *InitRequest) (*Empty, error)

func (UnimplementedCrowServer) Log 

func (UnimplementedCrowServer) Log(context.Context, *LogRequest) (*Empty, error)

func (UnimplementedCrowServer) Next 

func (UnimplementedCrowServer) Next(context.Context, *NextRequest) (*NextResponse, error)

func (UnimplementedCrowServer) RegisterAgent 

func (UnimplementedCrowServer) RegisterAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error)

func (UnimplementedCrowServer) ReportHealth 

func (UnimplementedCrowServer) ReportHealth(context.Context, *ReportHealthRequest) (*Empty, error)

func (UnimplementedCrowServer) UnregisterAgent 

func (UnimplementedCrowServer) UnregisterAgent(context.Context, *Empty) (*Empty, error)

func (UnimplementedCrowServer) Update 

func (UnimplementedCrowServer) Update(context.Context, *UpdateRequest) (*Empty, error)

func (UnimplementedCrowServer) Version 

func (UnimplementedCrowServer) Version(context.Context, *Empty) (*VersionResponse, error)

func (UnimplementedCrowServer) Wait 

func (UnimplementedCrowServer) Wait(context.Context, *WaitRequest) (*Empty, error)

type UnsafeCrowAuthServer 

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

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

type UnsafeCrowServer 

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

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

type UpdateRequest 

type UpdateRequest struct {
	Id    string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State *StepState `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (*UpdateRequest) GetId 

func (x *UpdateRequest) GetId() string

func (*UpdateRequest) GetState 

func (x *UpdateRequest) GetState() *StepState

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) ProtoReflect 

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

func (*UpdateRequest) Reset 

func (x *UpdateRequest) Reset()

func (*UpdateRequest) String 

func (x *UpdateRequest) String() string

type VersionResponse 

type VersionResponse struct {
	GrpcVersion   int32  `protobuf:"varint,1,opt,name=grpc_version,json=grpcVersion,proto3" json:"grpc_version,omitempty"`
	ServerVersion string `protobuf:"bytes,2,opt,name=server_version,json=serverVersion,proto3" json:"server_version,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionResponse) Descriptor deprecated 

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

Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.

func (*VersionResponse) GetGrpcVersion 

func (x *VersionResponse) GetGrpcVersion() int32

func (*VersionResponse) GetServerVersion 

func (x *VersionResponse) GetServerVersion() string

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) ProtoReflect 

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

func (*VersionResponse) Reset 

func (x *VersionResponse) Reset()

func (*VersionResponse) String 

func (x *VersionResponse) String() string

type WaitRequest 

type WaitRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitRequest) Descriptor deprecated 

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

Deprecated: Use WaitRequest.ProtoReflect.Descriptor instead.

func (*WaitRequest) GetId 

func (x *WaitRequest) GetId() string

func (*WaitRequest) ProtoMessage 

func (*WaitRequest) ProtoMessage()

func (*WaitRequest) ProtoReflect 

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

func (*WaitRequest) Reset 

func (x *WaitRequest) Reset()

func (*WaitRequest) String 

func (x *WaitRequest) String() string

type Workflow 

type Workflow struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Timeout int64  `protobuf:"varint,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*Workflow) Descriptor deprecated 

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

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetId 

func (x *Workflow) GetId() string

func (*Workflow) GetPayload 

func (x *Workflow) GetPayload() []byte

func (*Workflow) GetTimeout 

func (x *Workflow) GetTimeout() int64

func (*Workflow) ProtoMessage 

func (*Workflow) ProtoMessage()

func (*Workflow) ProtoReflect 

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

func (*Workflow) Reset 

func (x *Workflow) Reset()

func (*Workflow) String 

func (x *Workflow) String() string

type WorkflowState 

type WorkflowState struct {
	Started  int64  `protobuf:"varint,4,opt,name=started,proto3" json:"started,omitempty"`
	Finished int64  `protobuf:"varint,5,opt,name=finished,proto3" json:"finished,omitempty"`
	Error    string `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowState) Descriptor deprecated 

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

Deprecated: Use WorkflowState.ProtoReflect.Descriptor instead.

func (*WorkflowState) GetError 

func (x *WorkflowState) GetError() string

func (*WorkflowState) GetFinished 

func (x *WorkflowState) GetFinished() int64

func (*WorkflowState) GetStarted 

func (x *WorkflowState) GetStarted() int64

func (*WorkflowState) ProtoMessage 

func (*WorkflowState) ProtoMessage()

func (*WorkflowState) ProtoReflect 

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

func (*WorkflowState) Reset 

func (x *WorkflowState) Reset()

func (*WorkflowState) String 

func (x *WorkflowState) String() string

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.