pb

Documentation

Index

• Variables
• func RegisterTriggerServiceHandler(r http.Router, srv TriggerServiceHandler, opts ...http.HandleOption)
• func RegisterTriggerServiceImp(regester transport.Register, srv TriggerServiceServer, ...)
• func RegisterTriggerServiceServer(s grpc1.ServiceRegistrar, srv TriggerServiceServer, opts ...grpc1.HandleOption)
• func ServiceNames(svr ...string) []string
• func TriggerServiceClientType() reflect.Type
• func TriggerServiceHandlerType() reflect.Type
• func TriggerServiceServerType() reflect.Type
• func Types() []reflect.Type
• type PipelineTriggerRequest
  • func (*PipelineTriggerRequest) Descriptor() ([]byte, []int)
  • func (x *PipelineTriggerRequest) GetEventName() string
  • func (x *PipelineTriggerRequest) GetLabel() map[string]string
  • func (m *PipelineTriggerRequest) MarshalJSON() ([]byte, error)
  • func (*PipelineTriggerRequest) ProtoMessage()
  • func (x *PipelineTriggerRequest) ProtoReflect() protoreflect.Message
  • func (x *PipelineTriggerRequest) Reset()
  • func (x *PipelineTriggerRequest) String() string
  • func (m *PipelineTriggerRequest) UnmarshalJSON(b []byte) error
  • func (m *PipelineTriggerRequest) UnmarshalURLValues(prefix string, values url.Values) error
  • func (this *PipelineTriggerRequest) Validate() error
• type PipelineTriggerResponse
  • func (*PipelineTriggerResponse) Descriptor() ([]byte, []int)
  • func (x *PipelineTriggerResponse) GetPipelineIDs() []uint64
  • func (m *PipelineTriggerResponse) MarshalJSON() ([]byte, error)
  • func (*PipelineTriggerResponse) ProtoMessage()
  • func (x *PipelineTriggerResponse) ProtoReflect() protoreflect.Message
  • func (x *PipelineTriggerResponse) Reset()
  • func (x *PipelineTriggerResponse) String() string
  • func (m *PipelineTriggerResponse) UnmarshalJSON(b []byte) error
  • func (m *PipelineTriggerResponse) UnmarshalURLValues(prefix string, values url.Values) error
  • func (this *PipelineTriggerResponse) Validate() error
• type TriggerServiceClient
  • func NewTriggerServiceClient(cc grpc1.ClientConnInterface) TriggerServiceClient
• type TriggerServiceHandler
• type TriggerServiceServer
• type UnimplementedTriggerServiceServer
  • func (*UnimplementedTriggerServiceServer) RunPipelineByTriggerRequest(context.Context, *PipelineTriggerRequest) (*PipelineTriggerResponse, error)

Variables

var File_trigger_proto protoreflect.FileDescriptor

Functions

func RegisterTriggerServiceHandler

func RegisterTriggerServiceHandler(r http.Router, srv TriggerServiceHandler, opts ...http.HandleOption)

RegisterTriggerServiceHandler register TriggerServiceHandler to http.Router.

func RegisterTriggerServiceImp

func RegisterTriggerServiceImp(regester transport.Register, srv TriggerServiceServer, opts ...transport.ServiceOption)

RegisterTriggerServiceImp trigger.proto

func RegisterTriggerServiceServer

func RegisterTriggerServiceServer(s grpc1.ServiceRegistrar, srv TriggerServiceServer, opts ...grpc1.HandleOption)

func ServiceNames

func ServiceNames(svr ...string) []string

ServiceNames return all service names

func TriggerServiceClientType

func TriggerServiceClientType() reflect.Type

TriggerServiceClientType .

func TriggerServiceHandlerType

func TriggerServiceHandlerType() reflect.Type

TriggerServiceHandlerType .

func TriggerServiceServerType

func TriggerServiceServerType() reflect.Type

TriggerServiceServerType .

func Types

func Types() []reflect.Type

Types

type PipelineTriggerRequest

type PipelineTriggerRequest struct {
	EventName string            `protobuf:"bytes,1,opt,name=eventName,proto3" json:"eventName,omitempty"`
	Label     map[string]string `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PipelineTriggerRequest) Descriptor

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

Deprecated: Use PipelineTriggerRequest.ProtoReflect.Descriptor instead.

func (*PipelineTriggerRequest) GetEventName

func (x *PipelineTriggerRequest) GetEventName() string

func (*PipelineTriggerRequest) GetLabel

func (x *PipelineTriggerRequest) GetLabel() map[string]string

func (*PipelineTriggerRequest) MarshalJSON

func (m *PipelineTriggerRequest) MarshalJSON() ([]byte, error)

PipelineTriggerRequest implement json.Marshaler.

func (*PipelineTriggerRequest) ProtoMessage

func (*PipelineTriggerRequest) ProtoMessage()

func (*PipelineTriggerRequest) ProtoReflect

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

func (*PipelineTriggerRequest) Reset

func (x *PipelineTriggerRequest) Reset()

func (*PipelineTriggerRequest) String

func (x *PipelineTriggerRequest) String() string

func (*PipelineTriggerRequest) UnmarshalJSON

func (m *PipelineTriggerRequest) UnmarshalJSON(b []byte) error

PipelineTriggerRequest implement json.Marshaler.

func (*PipelineTriggerRequest) UnmarshalURLValues

func (m *PipelineTriggerRequest) UnmarshalURLValues(prefix string, values url.Values) error

PipelineTriggerRequest implement urlenc.URLValuesUnmarshaler.

func (*PipelineTriggerRequest) Validate

func (this *PipelineTriggerRequest) Validate() error

type PipelineTriggerResponse

type PipelineTriggerResponse struct {
	PipelineIDs []uint64 `protobuf:"varint,1,rep,packed,name=pipelineIDs,proto3" json:"pipelineIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineTriggerResponse) Descriptor

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

Deprecated: Use PipelineTriggerResponse.ProtoReflect.Descriptor instead.

func (*PipelineTriggerResponse) GetPipelineIDs

func (x *PipelineTriggerResponse) GetPipelineIDs() []uint64

func (*PipelineTriggerResponse) MarshalJSON

func (m *PipelineTriggerResponse) MarshalJSON() ([]byte, error)

PipelineTriggerResponse implement json.Marshaler.

func (*PipelineTriggerResponse) ProtoMessage

func (*PipelineTriggerResponse) ProtoMessage()

func (*PipelineTriggerResponse) ProtoReflect

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

func (*PipelineTriggerResponse) Reset

func (x *PipelineTriggerResponse) Reset()

func (*PipelineTriggerResponse) String

func (x *PipelineTriggerResponse) String() string

func (*PipelineTriggerResponse) UnmarshalJSON

func (m *PipelineTriggerResponse) UnmarshalJSON(b []byte) error

PipelineTriggerResponse implement json.Marshaler.

func (*PipelineTriggerResponse) UnmarshalURLValues

func (m *PipelineTriggerResponse) UnmarshalURLValues(prefix string, values url.Values) error

PipelineTriggerResponse implement urlenc.URLValuesUnmarshaler.

func (*PipelineTriggerResponse) Validate

func (this *PipelineTriggerResponse) Validate() error

type TriggerServiceClient

type TriggerServiceClient interface {
	RunPipelineByTriggerRequest(ctx context.Context, in *PipelineTriggerRequest, opts ...grpc.CallOption) (*PipelineTriggerResponse, error)
}

TriggerServiceClient is the client API for TriggerService 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 NewTriggerServiceClient

func NewTriggerServiceClient(cc grpc1.ClientConnInterface) TriggerServiceClient

type TriggerServiceHandler

type TriggerServiceHandler interface {
	// POST /api/pipeline/triggers/actions/run
	RunPipelineByTriggerRequest(context.Context, *PipelineTriggerRequest) (*PipelineTriggerResponse, error)
}

TriggerServiceHandler is the server API for TriggerService service.

type TriggerServiceServer

type TriggerServiceServer interface {
	RunPipelineByTriggerRequest(context.Context, *PipelineTriggerRequest) (*PipelineTriggerResponse, error)
}

TriggerServiceServer is the server API for TriggerService service. All implementations should embed UnimplementedTriggerServiceServer for forward compatibility

type UnimplementedTriggerServiceServer

type UnimplementedTriggerServiceServer struct {
}

UnimplementedTriggerServiceServer should be embedded to have forward compatible implementations.

func (*UnimplementedTriggerServiceServer) RunPipelineByTriggerRequest

func (*UnimplementedTriggerServiceServer) RunPipelineByTriggerRequest(context.Context, *PipelineTriggerRequest) (*PipelineTriggerResponse, error)