events

package
v1.0.1-0...-4418604 Latest Latest
Warning

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

 Go to latest Published: Feb 16, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

Package events is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	CreateEventRequest_EventType_name = map[int32]string{
		0: "CREATE",
		1: "READ",
		2: "UPDATE",
		3: "DELETE",
		4: "PROMOTE",
		5: "REQUEST_SCAN",
	}
	CreateEventRequest_EventType_value = map[string]int32{
		"CREATE":       0,
		"READ":         1,
		"UPDATE":       2,
		"DELETE":       3,
		"PROMOTE":      4,
		"REQUEST_SCAN": 5,
	}
)

Enum value maps for CreateEventRequest_EventType.

View Source 
var (
	WebhookCall_Status_name = map[int32]string{
		0: "UNKNOWN",
		1: "SUCCESS",
		2: "FAILURE",
		3: "IN_PROGRESS",
	}
	WebhookCall_Status_value = map[string]int32{
		"UNKNOWN":     0,
		"SUCCESS":     1,
		"FAILURE":     2,
		"IN_PROGRESS": 3,
	}
)

Enum value maps for WebhookCall_Status.

View Source 
var File_events_Event_proto protoreflect.FileDescriptor

Functions

func RegisterEventServiceHandler 

func RegisterEventServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterEventServiceHandler registers the http handlers for service EventService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterEventServiceHandlerClient 

func RegisterEventServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EventServiceClient) error

RegisterEventServiceHandlerClient registers the http handlers for service EventService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "EventServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "EventServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "EventServiceClient" to call the correct interceptors.

func RegisterEventServiceHandlerFromEndpoint 

func RegisterEventServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterEventServiceHandlerFromEndpoint is same as RegisterEventServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterEventServiceHandlerServer 

func RegisterEventServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EventServiceServer) error

RegisterEventServiceHandlerServer registers the http handlers for service EventService to "mux". UnaryRPC :call EventServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterEventServiceServer 

func RegisterEventServiceServer(s *grpc.Server, srv EventServiceServer)

Types

type CreateEventRequest 

type CreateEventRequest struct {
	EventUuid      string                       `protobuf:"bytes,1,opt,name=event_uuid,json=eventUuid,proto3" json:"event_uuid,omitempty"` // uuid for this event to handle deduplication
	EventType      CreateEventRequest_EventType ``                                                                                         /* 139-byte string literal not displayed */
	WorkspaceId    uint64                       `protobuf:"varint,3,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	Timestamp      uint64                       `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ResourceType   *uac.ResourceType            `protobuf:"bytes,5,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
	OriginalEntity *EventEntity                 `protobuf:"bytes,6,opt,name=original_entity,json=originalEntity,proto3" json:"original_entity,omitempty"`
	NewEntity      *EventEntity                 `protobuf:"bytes,7,opt,name=new_entity,json=newEntity,proto3" json:"new_entity,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateEventRequest) Descriptor deprecated 

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

Deprecated: Use CreateEventRequest.ProtoReflect.Descriptor instead.

func (*CreateEventRequest) GetEventType 

func (x *CreateEventRequest) GetEventType() CreateEventRequest_EventType

func (*CreateEventRequest) GetEventUuid 

func (x *CreateEventRequest) GetEventUuid() string

func (*CreateEventRequest) GetNewEntity 

func (x *CreateEventRequest) GetNewEntity() *EventEntity

func (*CreateEventRequest) GetOriginalEntity 

func (x *CreateEventRequest) GetOriginalEntity() *EventEntity

func (*CreateEventRequest) GetResourceType 

func (x *CreateEventRequest) GetResourceType() *uac.ResourceType

func (*CreateEventRequest) GetTimestamp 

func (x *CreateEventRequest) GetTimestamp() uint64

func (*CreateEventRequest) GetWorkspaceId 

func (x *CreateEventRequest) GetWorkspaceId() uint64

func (*CreateEventRequest) ProtoMessage 

func (*CreateEventRequest) ProtoMessage()

func (*CreateEventRequest) ProtoReflect 

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

func (*CreateEventRequest) Reset 

func (x *CreateEventRequest) Reset()

func (*CreateEventRequest) String 

func (x *CreateEventRequest) String() string

type CreateEventRequest_EventType 

type CreateEventRequest_EventType int32
const (
	CreateEventRequest_CREATE       CreateEventRequest_EventType = 0
	CreateEventRequest_READ         CreateEventRequest_EventType = 1
	CreateEventRequest_UPDATE       CreateEventRequest_EventType = 2
	CreateEventRequest_DELETE       CreateEventRequest_EventType = 3
	CreateEventRequest_PROMOTE      CreateEventRequest_EventType = 4
	CreateEventRequest_REQUEST_SCAN CreateEventRequest_EventType = 5
)

func (CreateEventRequest_EventType) Descriptor 

func (CreateEventRequest_EventType) Descriptor() protoreflect.EnumDescriptor

func (CreateEventRequest_EventType) Enum 

func (x CreateEventRequest_EventType) Enum() *CreateEventRequest_EventType

func (CreateEventRequest_EventType) EnumDescriptor deprecated 

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

Deprecated: Use CreateEventRequest_EventType.Descriptor instead.

func (CreateEventRequest_EventType) Number 

func (x CreateEventRequest_EventType) Number() protoreflect.EnumNumber

func (CreateEventRequest_EventType) String 

func (x CreateEventRequest_EventType) String() string

func (CreateEventRequest_EventType) Type 

func (CreateEventRequest_EventType) Type() protoreflect.EnumType

type CreateWebhookRequest 

type CreateWebhookRequest struct {
	Name          string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                   // Names must be unique within a workspace
	WorkspaceId   uint64              `protobuf:"varint,2,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"` // Optional
	Location      string              `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"`
	MutualSecret  string              `protobuf:"bytes,4,opt,name=mutual_secret,json=mutualSecret,proto3" json:"mutual_secret,omitempty"` // A shared secret between the two sides for validation. Check how this is passed by github (e.g. which header)
	EventTypes    []string            `protobuf:"bytes,5,rep,name=event_types,json=eventTypes,proto3" json:"event_types,omitempty"`
	AllEvents     bool                `protobuf:"varint,6,opt,name=all_events,json=allEvents,proto3" json:"all_events,omitempty"` // If true, we don't filter events that trigger the webhook by the event_type field. If false, we filter events using only the values in the event_types field.
	ResourceTypes []*uac.ResourceType `protobuf:"bytes,7,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateWebhookRequest) Descriptor deprecated 

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

Deprecated: Use CreateWebhookRequest.ProtoReflect.Descriptor instead.

func (*CreateWebhookRequest) GetAllEvents 

func (x *CreateWebhookRequest) GetAllEvents() bool

func (*CreateWebhookRequest) GetEventTypes 

func (x *CreateWebhookRequest) GetEventTypes() []string

func (*CreateWebhookRequest) GetLocation 

func (x *CreateWebhookRequest) GetLocation() string

func (*CreateWebhookRequest) GetMutualSecret 

func (x *CreateWebhookRequest) GetMutualSecret() string

func (*CreateWebhookRequest) GetName 

func (x *CreateWebhookRequest) GetName() string

func (*CreateWebhookRequest) GetResourceTypes 

func (x *CreateWebhookRequest) GetResourceTypes() []*uac.ResourceType

func (*CreateWebhookRequest) GetWorkspaceId 

func (x *CreateWebhookRequest) GetWorkspaceId() uint64

func (*CreateWebhookRequest) ProtoMessage 

func (*CreateWebhookRequest) ProtoMessage()

func (*CreateWebhookRequest) ProtoReflect 

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

func (*CreateWebhookRequest) Reset 

func (x *CreateWebhookRequest) Reset()

func (*CreateWebhookRequest) String 

func (x *CreateWebhookRequest) String() string

type DeleteWebhookRequest 

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

func (*DeleteWebhookRequest) Descriptor deprecated 

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

Deprecated: Use DeleteWebhookRequest.ProtoReflect.Descriptor instead.

func (*DeleteWebhookRequest) GetIds 

func (x *DeleteWebhookRequest) GetIds() []uint64

func (*DeleteWebhookRequest) ProtoMessage 

func (*DeleteWebhookRequest) ProtoMessage()

func (*DeleteWebhookRequest) ProtoReflect 

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

func (*DeleteWebhookRequest) Reset 

func (x *DeleteWebhookRequest) Reset()

func (*DeleteWebhookRequest) String 

func (x *DeleteWebhookRequest) String() string

type EventEntity 

type EventEntity struct {

	// Types that are assignable to Entity:
	//
	//	*EventEntity_RegisteredModel
	//	*EventEntity_ModelVersion
	//	*EventEntity_ScanRequest
	Entity            isEventEntity_Entity `protobuf_oneof:"entity"`
	EntityWorkspaceId uint64               `protobuf:"varint,3,opt,name=entity_workspace_id,json=entityWorkspaceId,proto3" json:"entity_workspace_id,omitempty"`
	// contains filtered or unexported fields
}

Lists all of the entity types that we support events for.

func (*EventEntity) Descriptor deprecated 

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

Deprecated: Use EventEntity.ProtoReflect.Descriptor instead.

func (*EventEntity) GetEntity 

func (m *EventEntity) GetEntity() isEventEntity_Entity

func (*EventEntity) GetEntityWorkspaceId 

func (x *EventEntity) GetEntityWorkspaceId() uint64

func (*EventEntity) GetModelVersion 

func (x *EventEntity) GetModelVersion() *registry.ModelVersion

func (*EventEntity) GetRegisteredModel 

func (x *EventEntity) GetRegisteredModel() *registry.RegisteredModel

func (*EventEntity) GetScanRequest 

func (x *EventEntity) GetScanRequest() *deployment.BuildExternalScanRequest

func (*EventEntity) ProtoMessage 

func (*EventEntity) ProtoMessage()

func (*EventEntity) ProtoReflect 

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

func (*EventEntity) Reset 

func (x *EventEntity) Reset()

func (*EventEntity) String 

func (x *EventEntity) String() string

type EventEntity_ModelVersion 

type EventEntity_ModelVersion struct {
	ModelVersion *registry.ModelVersion `protobuf:"bytes,2,opt,name=model_version,json=modelVersion,proto3,oneof"`
}

type EventEntity_RegisteredModel 

type EventEntity_RegisteredModel struct {
	RegisteredModel *registry.RegisteredModel `protobuf:"bytes,1,opt,name=registered_model,json=registeredModel,proto3,oneof"`
}

type EventEntity_ScanRequest 

type EventEntity_ScanRequest struct {
	ScanRequest *deployment.BuildExternalScanRequest `protobuf:"bytes,4,opt,name=scan_request,json=scanRequest,proto3,oneof"`
}

type EventServiceClient 

type EventServiceClient interface {
	CreateEvent(ctx context.Context, in *CreateEventRequest, opts ...grpc.CallOption) (*common.Empty, error)
	CreateWebhook(ctx context.Context, in *CreateWebhookRequest, opts ...grpc.CallOption) (*Webhook, error)
	UpdateWebhook(ctx context.Context, in *UpdateWebhookRequest, opts ...grpc.CallOption) (*Webhook, error)
	FindWebhook(ctx context.Context, in *FindWebhookRequest, opts ...grpc.CallOption) (*FindWebhookRequest_Response, error)
	DeleteWebhook(ctx context.Context, in *DeleteWebhookRequest, opts ...grpc.CallOption) (*common.Empty, error)
	FindWebhookCall(ctx context.Context, in *FindWebhookCallRequest, opts ...grpc.CallOption) (*FindWebhookCallRequest_Response, error)
	RetriggerWebhookCall(ctx context.Context, in *RetriggerWebhookCallRequest, opts ...grpc.CallOption) (*WebhookCall, error)
	TriggerTest(ctx context.Context, in *TestWebhookRequest, opts ...grpc.CallOption) (*TestWebhookRequest_Response, error)
}

EventServiceClient is the client API for EventService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEventServiceClient 

func NewEventServiceClient(cc grpc.ClientConnInterface) EventServiceClient

type EventServiceServer 

type EventServiceServer interface {
	CreateEvent(context.Context, *CreateEventRequest) (*common.Empty, error)
	CreateWebhook(context.Context, *CreateWebhookRequest) (*Webhook, error)
	UpdateWebhook(context.Context, *UpdateWebhookRequest) (*Webhook, error)
	FindWebhook(context.Context, *FindWebhookRequest) (*FindWebhookRequest_Response, error)
	DeleteWebhook(context.Context, *DeleteWebhookRequest) (*common.Empty, error)
	FindWebhookCall(context.Context, *FindWebhookCallRequest) (*FindWebhookCallRequest_Response, error)
	RetriggerWebhookCall(context.Context, *RetriggerWebhookCallRequest) (*WebhookCall, error)
	TriggerTest(context.Context, *TestWebhookRequest) (*TestWebhookRequest_Response, error)
}

EventServiceServer is the server API for EventService service.

type FindWebhookCallRequest 

type FindWebhookCallRequest struct {
	Ids        []uint64             `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	WebhookIds []uint64             `protobuf:"varint,2,rep,packed,name=webhook_ids,json=webhookIds,proto3" json:"webhook_ids,omitempty"`
	EventUuids []string             `protobuf:"bytes,3,rep,name=event_uuids,json=eventUuids,proto3" json:"event_uuids,omitempty"`
	Status     []WebhookCall_Status `protobuf:"varint,4,rep,packed,name=status,proto3,enum=ai.verta.events.WebhookCall_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*FindWebhookCallRequest) Descriptor deprecated 

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

Deprecated: Use FindWebhookCallRequest.ProtoReflect.Descriptor instead.

func (*FindWebhookCallRequest) GetEventUuids 

func (x *FindWebhookCallRequest) GetEventUuids() []string

func (*FindWebhookCallRequest) GetIds 

func (x *FindWebhookCallRequest) GetIds() []uint64

func (*FindWebhookCallRequest) GetStatus 

func (x *FindWebhookCallRequest) GetStatus() []WebhookCall_Status

func (*FindWebhookCallRequest) GetWebhookIds 

func (x *FindWebhookCallRequest) GetWebhookIds() []uint64

func (*FindWebhookCallRequest) ProtoMessage 

func (*FindWebhookCallRequest) ProtoMessage()

func (*FindWebhookCallRequest) ProtoReflect 

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

func (*FindWebhookCallRequest) Reset 

func (x *FindWebhookCallRequest) Reset()

func (*FindWebhookCallRequest) String 

func (x *FindWebhookCallRequest) String() string

type FindWebhookCallRequest_Response 

type FindWebhookCallRequest_Response struct {
	Calls []*WebhookCall `protobuf:"bytes,1,rep,name=calls,proto3" json:"calls,omitempty"`
	// contains filtered or unexported fields
}

func (*FindWebhookCallRequest_Response) Descriptor deprecated 

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

Deprecated: Use FindWebhookCallRequest_Response.ProtoReflect.Descriptor instead.

func (*FindWebhookCallRequest_Response) GetCalls 

func (x *FindWebhookCallRequest_Response) GetCalls() []*WebhookCall

func (*FindWebhookCallRequest_Response) ProtoMessage 

func (*FindWebhookCallRequest_Response) ProtoMessage()

func (*FindWebhookCallRequest_Response) ProtoReflect 

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

func (*FindWebhookCallRequest_Response) Reset 

func (x *FindWebhookCallRequest_Response) Reset()

func (*FindWebhookCallRequest_Response) String 

func (x *FindWebhookCallRequest_Response) String() string

type FindWebhookRequest 

type FindWebhookRequest struct {
	Ids           []uint64            `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	Names         []string            `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"`
	WorkspaceId   []uint64            `protobuf:"varint,3,rep,packed,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	ResourceTypes []*uac.ResourceType `protobuf:"bytes,4,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,omitempty"`
	// contains filtered or unexported fields
}

func (*FindWebhookRequest) Descriptor deprecated 

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

Deprecated: Use FindWebhookRequest.ProtoReflect.Descriptor instead.

func (*FindWebhookRequest) GetIds 

func (x *FindWebhookRequest) GetIds() []uint64

func (*FindWebhookRequest) GetNames 

func (x *FindWebhookRequest) GetNames() []string

func (*FindWebhookRequest) GetResourceTypes 

func (x *FindWebhookRequest) GetResourceTypes() []*uac.ResourceType

func (*FindWebhookRequest) GetWorkspaceId 

func (x *FindWebhookRequest) GetWorkspaceId() []uint64

func (*FindWebhookRequest) ProtoMessage 

func (*FindWebhookRequest) ProtoMessage()

func (*FindWebhookRequest) ProtoReflect 

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

func (*FindWebhookRequest) Reset 

func (x *FindWebhookRequest) Reset()

func (*FindWebhookRequest) String 

func (x *FindWebhookRequest) String() string

type FindWebhookRequest_Response 

type FindWebhookRequest_Response struct {
	Webhooks []*Webhook `protobuf:"bytes,1,rep,name=webhooks,proto3" json:"webhooks,omitempty"`
	// contains filtered or unexported fields
}

func (*FindWebhookRequest_Response) Descriptor deprecated 

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

Deprecated: Use FindWebhookRequest_Response.ProtoReflect.Descriptor instead.

func (*FindWebhookRequest_Response) GetWebhooks 

func (x *FindWebhookRequest_Response) GetWebhooks() []*Webhook

func (*FindWebhookRequest_Response) ProtoMessage 

func (*FindWebhookRequest_Response) ProtoMessage()

func (*FindWebhookRequest_Response) ProtoReflect 

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

func (*FindWebhookRequest_Response) Reset 

func (x *FindWebhookRequest_Response) Reset()

func (*FindWebhookRequest_Response) String 

func (x *FindWebhookRequest_Response) String() string

type RetriggerWebhookCallRequest 

type RetriggerWebhookCallRequest struct {
	CallId uint64 `protobuf:"varint,1,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
	// contains filtered or unexported fields
}

The call returned for this has a completely new ID

func (*RetriggerWebhookCallRequest) Descriptor deprecated 

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

Deprecated: Use RetriggerWebhookCallRequest.ProtoReflect.Descriptor instead.

func (*RetriggerWebhookCallRequest) GetCallId 

func (x *RetriggerWebhookCallRequest) GetCallId() uint64

func (*RetriggerWebhookCallRequest) ProtoMessage 

func (*RetriggerWebhookCallRequest) ProtoMessage()

func (*RetriggerWebhookCallRequest) ProtoReflect 

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

func (*RetriggerWebhookCallRequest) Reset 

func (x *RetriggerWebhookCallRequest) Reset()

func (*RetriggerWebhookCallRequest) String 

func (x *RetriggerWebhookCallRequest) String() string

type TestWebhookRequest 

type TestWebhookRequest struct {
	WebhookId uint64 `protobuf:"varint,1,opt,name=webhook_id,json=webhookId,proto3" json:"webhook_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TestWebhookRequest) Descriptor deprecated 

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

Deprecated: Use TestWebhookRequest.ProtoReflect.Descriptor instead.

func (*TestWebhookRequest) GetWebhookId 

func (x *TestWebhookRequest) GetWebhookId() uint64

func (*TestWebhookRequest) ProtoMessage 

func (*TestWebhookRequest) ProtoMessage()

func (*TestWebhookRequest) ProtoReflect 

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

func (*TestWebhookRequest) Reset 

func (x *TestWebhookRequest) Reset()

func (*TestWebhookRequest) String 

func (x *TestWebhookRequest) String() string

type TestWebhookRequest_Response 

type TestWebhookRequest_Response struct {
	StatusCode uint64 `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	// contains filtered or unexported fields
}

func (*TestWebhookRequest_Response) Descriptor deprecated 

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

Deprecated: Use TestWebhookRequest_Response.ProtoReflect.Descriptor instead.

func (*TestWebhookRequest_Response) GetStatusCode 

func (x *TestWebhookRequest_Response) GetStatusCode() uint64

func (*TestWebhookRequest_Response) ProtoMessage 

func (*TestWebhookRequest_Response) ProtoMessage()

func (*TestWebhookRequest_Response) ProtoReflect 

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

func (*TestWebhookRequest_Response) Reset 

func (x *TestWebhookRequest_Response) Reset()

func (*TestWebhookRequest_Response) String 

func (x *TestWebhookRequest_Response) String() string

type UnimplementedEventServiceServer 

type UnimplementedEventServiceServer struct {
}

UnimplementedEventServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventServiceServer) CreateEvent 

func (*UnimplementedEventServiceServer) CreateEvent(context.Context, *CreateEventRequest) (*common.Empty, error)

func (*UnimplementedEventServiceServer) CreateWebhook 

func (*UnimplementedEventServiceServer) CreateWebhook(context.Context, *CreateWebhookRequest) (*Webhook, error)

func (*UnimplementedEventServiceServer) DeleteWebhook 

func (*UnimplementedEventServiceServer) DeleteWebhook(context.Context, *DeleteWebhookRequest) (*common.Empty, error)

func (*UnimplementedEventServiceServer) FindWebhook 

func (*UnimplementedEventServiceServer) FindWebhook(context.Context, *FindWebhookRequest) (*FindWebhookRequest_Response, error)

func (*UnimplementedEventServiceServer) FindWebhookCall 

func (*UnimplementedEventServiceServer) FindWebhookCall(context.Context, *FindWebhookCallRequest) (*FindWebhookCallRequest_Response, error)

func (*UnimplementedEventServiceServer) RetriggerWebhookCall 

func (*UnimplementedEventServiceServer) RetriggerWebhookCall(context.Context, *RetriggerWebhookCallRequest) (*WebhookCall, error)

func (*UnimplementedEventServiceServer) TriggerTest 

func (*UnimplementedEventServiceServer) TriggerTest(context.Context, *TestWebhookRequest) (*TestWebhookRequest_Response, error)

func (*UnimplementedEventServiceServer) UpdateWebhook 

func (*UnimplementedEventServiceServer) UpdateWebhook(context.Context, *UpdateWebhookRequest) (*Webhook, error)

type UpdateWebhookRequest 

type UpdateWebhookRequest struct {
	Id                  uint64              `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	NewLocation         string              `protobuf:"bytes,2,opt,name=new_location,json=newLocation,proto3" json:"new_location,omitempty"`    // Optional. If empty, keep the current setting
	MutualSecret        string              `protobuf:"bytes,3,opt,name=mutual_secret,json=mutualSecret,proto3" json:"mutual_secret,omitempty"` // Optional. If empty, keep the current setting
	AddEventTypes       []string            `protobuf:"bytes,4,rep,name=add_event_types,json=addEventTypes,proto3" json:"add_event_types,omitempty"`
	DeleteEventTypes    []string            `protobuf:"bytes,5,rep,name=delete_event_types,json=deleteEventTypes,proto3" json:"delete_event_types,omitempty"`
	SetAllEvents        bool                `protobuf:"varint,6,opt,name=set_all_events,json=setAllEvents,proto3" json:"set_all_events,omitempty"`
	ClearAllEvents      bool                `protobuf:"varint,7,opt,name=clear_all_events,json=clearAllEvents,proto3" json:"clear_all_events,omitempty"`
	AddResourceTypes    []*uac.ResourceType `protobuf:"bytes,8,rep,name=add_resource_types,json=addResourceTypes,proto3" json:"add_resource_types,omitempty"`
	DeleteResourceTypes []*uac.ResourceType `protobuf:"bytes,9,rep,name=delete_resource_types,json=deleteResourceTypes,proto3" json:"delete_resource_types,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateWebhookRequest) Descriptor deprecated 

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

Deprecated: Use UpdateWebhookRequest.ProtoReflect.Descriptor instead.

func (*UpdateWebhookRequest) GetAddEventTypes 

func (x *UpdateWebhookRequest) GetAddEventTypes() []string

func (*UpdateWebhookRequest) GetAddResourceTypes 

func (x *UpdateWebhookRequest) GetAddResourceTypes() []*uac.ResourceType

func (*UpdateWebhookRequest) GetClearAllEvents 

func (x *UpdateWebhookRequest) GetClearAllEvents() bool

func (*UpdateWebhookRequest) GetDeleteEventTypes 

func (x *UpdateWebhookRequest) GetDeleteEventTypes() []string

func (*UpdateWebhookRequest) GetDeleteResourceTypes 

func (x *UpdateWebhookRequest) GetDeleteResourceTypes() []*uac.ResourceType

func (*UpdateWebhookRequest) GetId 

func (x *UpdateWebhookRequest) GetId() uint64

func (*UpdateWebhookRequest) GetMutualSecret 

func (x *UpdateWebhookRequest) GetMutualSecret() string

func (*UpdateWebhookRequest) GetNewLocation 

func (x *UpdateWebhookRequest) GetNewLocation() string

func (*UpdateWebhookRequest) GetSetAllEvents 

func (x *UpdateWebhookRequest) GetSetAllEvents() bool

func (*UpdateWebhookRequest) ProtoMessage 

func (*UpdateWebhookRequest) ProtoMessage()

func (*UpdateWebhookRequest) ProtoReflect 

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

func (*UpdateWebhookRequest) Reset 

func (x *UpdateWebhookRequest) Reset()

func (*UpdateWebhookRequest) String 

func (x *UpdateWebhookRequest) String() string

type Webhook 

type Webhook struct {
	Id            uint64              `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name          string              `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                                   // Names must be unique within a workspace
	WorkspaceId   uint64              `protobuf:"varint,3,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"` // Optional
	Location      string              `protobuf:"bytes,4,opt,name=location,proto3" json:"location,omitempty"`
	MutualSecret  string              `protobuf:"bytes,5,opt,name=mutual_secret,json=mutualSecret,proto3" json:"mutual_secret,omitempty"` // A shared secret between the two sides for validation
	EventTypes    []string            `protobuf:"bytes,6,rep,name=event_types,json=eventTypes,proto3" json:"event_types,omitempty"`
	ResourceTypes []*uac.ResourceType `protobuf:"bytes,7,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,omitempty"`
	// contains filtered or unexported fields
}

func (*Webhook) Descriptor deprecated 

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

Deprecated: Use Webhook.ProtoReflect.Descriptor instead.

func (*Webhook) GetEventTypes 

func (x *Webhook) GetEventTypes() []string

func (*Webhook) GetId 

func (x *Webhook) GetId() uint64

func (*Webhook) GetLocation 

func (x *Webhook) GetLocation() string

func (*Webhook) GetMutualSecret 

func (x *Webhook) GetMutualSecret() string

func (*Webhook) GetName 

func (x *Webhook) GetName() string

func (*Webhook) GetResourceTypes 

func (x *Webhook) GetResourceTypes() []*uac.ResourceType

func (*Webhook) GetWorkspaceId 

func (x *Webhook) GetWorkspaceId() uint64

func (*Webhook) ProtoMessage 

func (*Webhook) ProtoMessage()

func (*Webhook) ProtoReflect 

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

func (*Webhook) Reset 

func (x *Webhook) Reset()

func (*Webhook) String 

func (x *Webhook) String() string

type WebhookCall 

type WebhookCall struct {
	Id        uint64             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	WebhookId uint64             `protobuf:"varint,2,opt,name=webhook_id,json=webhookId,proto3" json:"webhook_id,omitempty"`
	EventUuid string             `protobuf:"bytes,3,opt,name=event_uuid,json=eventUuid,proto3" json:"event_uuid,omitempty"`
	Status    WebhookCall_Status `protobuf:"varint,4,opt,name=status,proto3,enum=ai.verta.events.WebhookCall_Status" json:"status,omitempty"`
	Response  *any1.Any          `protobuf:"bytes,5,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

Single call of a webhook to deliver a given event

func (*WebhookCall) Descriptor deprecated 

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

Deprecated: Use WebhookCall.ProtoReflect.Descriptor instead.

func (*WebhookCall) GetEventUuid 

func (x *WebhookCall) GetEventUuid() string

func (*WebhookCall) GetId 

func (x *WebhookCall) GetId() uint64

func (*WebhookCall) GetResponse 

func (x *WebhookCall) GetResponse() *any1.Any

func (*WebhookCall) GetStatus 

func (x *WebhookCall) GetStatus() WebhookCall_Status

func (*WebhookCall) GetWebhookId 

func (x *WebhookCall) GetWebhookId() uint64

func (*WebhookCall) ProtoMessage 

func (*WebhookCall) ProtoMessage()

func (*WebhookCall) ProtoReflect 

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

func (*WebhookCall) Reset 

func (x *WebhookCall) Reset()

func (*WebhookCall) String 

func (x *WebhookCall) String() string

type WebhookCall_Status 

type WebhookCall_Status int32
const (
	WebhookCall_UNKNOWN     WebhookCall_Status = 0
	WebhookCall_SUCCESS     WebhookCall_Status = 1
	WebhookCall_FAILURE     WebhookCall_Status = 2
	WebhookCall_IN_PROGRESS WebhookCall_Status = 3
)

func (WebhookCall_Status) Descriptor 

func (WebhookCall_Status) Descriptor() protoreflect.EnumDescriptor

func (WebhookCall_Status) Enum 

func (x WebhookCall_Status) Enum() *WebhookCall_Status

func (WebhookCall_Status) EnumDescriptor deprecated 

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

Deprecated: Use WebhookCall_Status.Descriptor instead.

func (WebhookCall_Status) Number 

func (x WebhookCall_Status) Number() protoreflect.EnumNumber

func (WebhookCall_Status) String 

func (x WebhookCall_Status) String() string

func (WebhookCall_Status) Type 

func (WebhookCall_Status) Type() protoreflect.EnumType

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.