audit

package
v0.0.0-...-b49d8ae Latest Latest
Warning

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

 Go to latest Published: Sep 26, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AuditService_List_FullMethodName           = "/InternalApi.Audit.AuditService/List"
	AuditService_PaginatedList_FullMethodName  = "/InternalApi.Audit.AuditService/PaginatedList"
	AuditService_TestStream_FullMethodName     = "/InternalApi.Audit.AuditService/TestStream"
	AuditService_CreateStream_FullMethodName   = "/InternalApi.Audit.AuditService/CreateStream"
	AuditService_DescribeStream_FullMethodName = "/InternalApi.Audit.AuditService/DescribeStream"
	AuditService_UpdateStream_FullMethodName   = "/InternalApi.Audit.AuditService/UpdateStream"
	AuditService_DestroyStream_FullMethodName  = "/InternalApi.Audit.AuditService/DestroyStream"
	AuditService_SetStreamState_FullMethodName = "/InternalApi.Audit.AuditService/SetStreamState"
	AuditService_ListStreamLogs_FullMethodName = "/InternalApi.Audit.AuditService/ListStreamLogs"
)

Variables

View Source 
var (
	StreamProvider_name = map[int32]string{
		0: "S3",
	}
	StreamProvider_value = map[string]int32{
		"S3": 0,
	}
)

Enum value maps for StreamProvider.

View Source 
var (
	StreamStatus_name = map[int32]string{
		0: "ACTIVE",
		1: "PAUSED",
	}
	StreamStatus_value = map[string]int32{
		"ACTIVE": 0,
		"PAUSED": 1,
	}
)

Enum value maps for StreamStatus.

View Source 
var (
	PaginatedListRequest_Direction_name = map[int32]string{
		0: "NEXT",
		1: "PREVIOUS",
	}
	PaginatedListRequest_Direction_value = map[string]int32{
		"NEXT":     0,
		"PREVIOUS": 1,
	}
)

Enum value maps for PaginatedListRequest_Direction.

View Source 
var (
	ListStreamLogsRequest_Direction_name = map[int32]string{
		0: "NEXT",
		1: "PREVIOUS",
	}
	ListStreamLogsRequest_Direction_value = map[string]int32{
		"NEXT":     0,
		"PREVIOUS": 1,
	}
)

Enum value maps for ListStreamLogsRequest_Direction.

View Source 
var (
	S3StreamConfig_Type_name = map[int32]string{
		0: "USER",
		1: "INSTANCE_ROLE",
	}
	S3StreamConfig_Type_value = map[string]int32{
		"USER":          0,
		"INSTANCE_ROLE": 1,
	}
)

Enum value maps for S3StreamConfig_Type.

View Source 
var (
	Event_Resource_name = map[int32]string{
		0:  "Project",
		1:  "User",
		2:  "Workflow",
		3:  "Pipeline",
		4:  "DebugSession",
		5:  "PeriodicScheduler",
		6:  "Secret",
		7:  "Notification",
		8:  "Dashboard",
		9:  "Job",
		10: "Artifact",
		11: "Organization",
		12: "SelfHostedAgentType",
		13: "SelfHostedAgent",
		14: "CustomDashboard",
		15: "CustomDashboardItem",
		16: "ProjectInsightsSettings",
		17: "Okta",
		18: "FlakyTests",
		19: "RBACRole",
	}
	Event_Resource_value = map[string]int32{
		"Project":                 0,
		"User":                    1,
		"Workflow":                2,
		"Pipeline":                3,
		"DebugSession":            4,
		"PeriodicScheduler":       5,
		"Secret":                  6,
		"Notification":            7,
		"Dashboard":               8,
		"Job":                     9,
		"Artifact":                10,
		"Organization":            11,
		"SelfHostedAgentType":     12,
		"SelfHostedAgent":         13,
		"CustomDashboard":         14,
		"CustomDashboardItem":     15,
		"ProjectInsightsSettings": 16,
		"Okta":                    17,
		"FlakyTests":              18,
		"RBACRole":                19,
	}
)

Enum value maps for Event_Resource.

View Source 
var (
	Event_Operation_name = map[int32]string{
		0: "Added",
		1: "Removed",
		2: "Modified",
		3: "Started",
		4: "Stopped",
		5: "Promoted",
		6: "Demoted",
		7: "Rebuild",
		8: "Download",
		9: "Disabled",
	}
	Event_Operation_value = map[string]int32{
		"Added":    0,
		"Removed":  1,
		"Modified": 2,
		"Started":  3,
		"Stopped":  4,
		"Promoted": 5,
		"Demoted":  6,
		"Rebuild":  7,
		"Download": 8,
		"Disabled": 9,
	}
)

Enum value maps for Event_Operation.

View Source 
var (
	Event_Medium_name = map[int32]string{
		0: "Web",
		1: "API",
		2: "CLI",
	}
	Event_Medium_value = map[string]int32{
		"Web": 0,
		"API": 1,
		"CLI": 2,
	}
)

Enum value maps for Event_Medium.

View Source 
var AuditService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "InternalApi.Audit.AuditService",
	HandlerType: (*AuditServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "List",
			Handler:    _AuditService_List_Handler,
		},
		{
			MethodName: "PaginatedList",
			Handler:    _AuditService_PaginatedList_Handler,
		},
		{
			MethodName: "TestStream",
			Handler:    _AuditService_TestStream_Handler,
		},
		{
			MethodName: "CreateStream",
			Handler:    _AuditService_CreateStream_Handler,
		},
		{
			MethodName: "DescribeStream",
			Handler:    _AuditService_DescribeStream_Handler,
		},
		{
			MethodName: "UpdateStream",
			Handler:    _AuditService_UpdateStream_Handler,
		},
		{
			MethodName: "DestroyStream",
			Handler:    _AuditService_DestroyStream_Handler,
		},
		{
			MethodName: "SetStreamState",
			Handler:    _AuditService_SetStreamState_Handler,
		},
		{
			MethodName: "ListStreamLogs",
			Handler:    _AuditService_ListStreamLogs_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "audit.proto",
}

AuditService_ServiceDesc is the grpc.ServiceDesc for AuditService 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_audit_proto protoreflect.FileDescriptor

Functions

func RegisterAuditServiceServer 

func RegisterAuditServiceServer(s grpc.ServiceRegistrar, srv AuditServiceServer)

Types

type AuditServiceClient 

type AuditServiceClient interface {
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	PaginatedList(ctx context.Context, in *PaginatedListRequest, opts ...grpc.CallOption) (*PaginatedListResponse, error)
	// CRUD for config of Audit log exporting
	TestStream(ctx context.Context, in *TestStreamRequest, opts ...grpc.CallOption) (*TestStreamResponse, error)
	CreateStream(ctx context.Context, in *CreateStreamRequest, opts ...grpc.CallOption) (*CreateStreamResponse, error)
	DescribeStream(ctx context.Context, in *DescribeStreamRequest, opts ...grpc.CallOption) (*DescribeStreamResponse, error)
	UpdateStream(ctx context.Context, in *UpdateStreamRequest, opts ...grpc.CallOption) (*UpdateStreamResponse, error)
	DestroyStream(ctx context.Context, in *DestroyStreamRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// PAUSE/RESUME for any type of Audit log exporting
	SetStreamState(ctx context.Context, in *SetStreamStateRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ListStreamLogs(ctx context.Context, in *ListStreamLogsRequest, opts ...grpc.CallOption) (*ListStreamLogsResponse, error)
}

AuditServiceClient is the client API for AuditService 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 NewAuditServiceClient 

func NewAuditServiceClient(cc grpc.ClientConnInterface) AuditServiceClient

type AuditServiceServer 

type AuditServiceServer interface {
	List(context.Context, *ListRequest) (*ListResponse, error)
	PaginatedList(context.Context, *PaginatedListRequest) (*PaginatedListResponse, error)
	// CRUD for config of Audit log exporting
	TestStream(context.Context, *TestStreamRequest) (*TestStreamResponse, error)
	CreateStream(context.Context, *CreateStreamRequest) (*CreateStreamResponse, error)
	DescribeStream(context.Context, *DescribeStreamRequest) (*DescribeStreamResponse, error)
	UpdateStream(context.Context, *UpdateStreamRequest) (*UpdateStreamResponse, error)
	DestroyStream(context.Context, *DestroyStreamRequest) (*empty.Empty, error)
	// PAUSE/RESUME for any type of Audit log exporting
	SetStreamState(context.Context, *SetStreamStateRequest) (*empty.Empty, error)
	ListStreamLogs(context.Context, *ListStreamLogsRequest) (*ListStreamLogsResponse, error)
}

AuditServiceServer is the server API for AuditService service. All implementations should embed UnimplementedAuditServiceServer for forward compatibility.

type CreateStreamRequest 

type CreateStreamRequest struct {
	Stream *Stream `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	UserId string  `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateStreamRequest) Descriptor deprecated 

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

Deprecated: Use CreateStreamRequest.ProtoReflect.Descriptor instead.

func (*CreateStreamRequest) GetStream 

func (x *CreateStreamRequest) GetStream() *Stream

func (*CreateStreamRequest) GetUserId 

func (x *CreateStreamRequest) GetUserId() string

func (*CreateStreamRequest) ProtoMessage 

func (*CreateStreamRequest) ProtoMessage()

func (*CreateStreamRequest) ProtoReflect 

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

func (*CreateStreamRequest) Reset 

func (x *CreateStreamRequest) Reset()

func (*CreateStreamRequest) String 

func (x *CreateStreamRequest) String() string

type CreateStreamResponse 

type CreateStreamResponse struct {
	Stream *Stream   `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	Meta   *EditMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateStreamResponse) Descriptor deprecated 

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

Deprecated: Use CreateStreamResponse.ProtoReflect.Descriptor instead.

func (*CreateStreamResponse) GetMeta 

func (x *CreateStreamResponse) GetMeta() *EditMeta

func (*CreateStreamResponse) GetStream 

func (x *CreateStreamResponse) GetStream() *Stream

func (*CreateStreamResponse) ProtoMessage 

func (*CreateStreamResponse) ProtoMessage()

func (*CreateStreamResponse) ProtoReflect 

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

func (*CreateStreamResponse) Reset 

func (x *CreateStreamResponse) Reset()

func (*CreateStreamResponse) String 

func (x *CreateStreamResponse) String() string

type DescribeStreamRequest 

type DescribeStreamRequest struct {
	OrgId string `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeStreamRequest) Descriptor deprecated 

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

Deprecated: Use DescribeStreamRequest.ProtoReflect.Descriptor instead.

func (*DescribeStreamRequest) GetOrgId 

func (x *DescribeStreamRequest) GetOrgId() string

func (*DescribeStreamRequest) ProtoMessage 

func (*DescribeStreamRequest) ProtoMessage()

func (*DescribeStreamRequest) ProtoReflect 

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

func (*DescribeStreamRequest) Reset 

func (x *DescribeStreamRequest) Reset()

func (*DescribeStreamRequest) String 

func (x *DescribeStreamRequest) String() string

type DescribeStreamResponse 

type DescribeStreamResponse struct {
	Stream *Stream   `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	Meta   *EditMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeStreamResponse) Descriptor deprecated 

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

Deprecated: Use DescribeStreamResponse.ProtoReflect.Descriptor instead.

func (*DescribeStreamResponse) GetMeta 

func (x *DescribeStreamResponse) GetMeta() *EditMeta

func (*DescribeStreamResponse) GetStream 

func (x *DescribeStreamResponse) GetStream() *Stream

func (*DescribeStreamResponse) ProtoMessage 

func (*DescribeStreamResponse) ProtoMessage()

func (*DescribeStreamResponse) ProtoReflect 

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

func (*DescribeStreamResponse) Reset 

func (x *DescribeStreamResponse) Reset()

func (*DescribeStreamResponse) String 

func (x *DescribeStreamResponse) String() string

type DestroyStreamRequest 

type DestroyStreamRequest struct {
	OrgId string `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DestroyStreamRequest) Descriptor deprecated 

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

Deprecated: Use DestroyStreamRequest.ProtoReflect.Descriptor instead.

func (*DestroyStreamRequest) GetOrgId 

func (x *DestroyStreamRequest) GetOrgId() string

func (*DestroyStreamRequest) ProtoMessage 

func (*DestroyStreamRequest) ProtoMessage()

func (*DestroyStreamRequest) ProtoReflect 

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

func (*DestroyStreamRequest) Reset 

func (x *DestroyStreamRequest) Reset()

func (*DestroyStreamRequest) String 

func (x *DestroyStreamRequest) String() string

type EditMeta 

type EditMeta struct {
	CreatedAt         *timestamp.Timestamp `protobuf:"bytes,1,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt         *timestamp.Timestamp `protobuf:"bytes,2,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	ActivityToggledAt *timestamp.Timestamp `protobuf:"bytes,3,opt,name=activity_toggled_at,json=activityToggledAt,proto3" json:"activity_toggled_at,omitempty"`
	UpdatedBy         string               `protobuf:"bytes,4,opt,name=updated_by,json=updatedBy,proto3" json:"updated_by,omitempty"`
	ActivityToggledBy string               `protobuf:"bytes,5,opt,name=activity_toggled_by,json=activityToggledBy,proto3" json:"activity_toggled_by,omitempty"`
	// contains filtered or unexported fields
}

EditMeta contains Stream data

func (*EditMeta) Descriptor deprecated 

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

Deprecated: Use EditMeta.ProtoReflect.Descriptor instead.

func (*EditMeta) GetActivityToggledAt 

func (x *EditMeta) GetActivityToggledAt() *timestamp.Timestamp

func (*EditMeta) GetActivityToggledBy 

func (x *EditMeta) GetActivityToggledBy() string

func (*EditMeta) GetCreatedAt 

func (x *EditMeta) GetCreatedAt() *timestamp.Timestamp

func (*EditMeta) GetUpdatedAt 

func (x *EditMeta) GetUpdatedAt() *timestamp.Timestamp

func (*EditMeta) GetUpdatedBy 

func (x *EditMeta) GetUpdatedBy() string

func (*EditMeta) ProtoMessage 

func (*EditMeta) ProtoMessage()

func (*EditMeta) ProtoReflect 

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

func (*EditMeta) Reset 

func (x *EditMeta) Reset()

func (*EditMeta) String 

func (x *EditMeta) String() string

type Event 

type Event struct {
	Resource  Event_Resource  `protobuf:"varint,1,opt,name=resource,proto3,enum=InternalApi.Audit.Event_Resource" json:"resource,omitempty"`    // [required]
	Operation Event_Operation `protobuf:"varint,2,opt,name=operation,proto3,enum=InternalApi.Audit.Event_Operation" json:"operation,omitempty"` // [required]
	UserId    string          `protobuf:"bytes,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`                                 // [required] The user who initiated this action.
	OrgId     string          `protobuf:"bytes,4,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`                                    // [required] Organization ID in which this event happened.
	IpAddress string          `protobuf:"bytes,5,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`                        // [optional] The user's IP address when he run the operation.
	// [optional]
	//
	// If username is not provided, the Audit system will use the user_id to look
	// up the username. This allows the sender to not worry about fetching the
	// username and the performance implications that this might add to the system.
	//
	// However, on user delete, the username of the user might no longer be
	// available. Providing the username in regular audit logs is not
	// necessary, as it will be loaded by the Audit service.
	//
	// Not providing the username (only the user_id) is cheaper
	// performance wise to some services.
	Username string `protobuf:"bytes,6,opt,name=username,proto3" json:"username,omitempty"`
	// [optinal] Short textual description of the action.
	Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`
	// [optinal] JSON Metadata. Must be a valid JSON.
	Metadata  string               `protobuf:"bytes,8,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,9,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // [required]
	// [required]
	//
	// An ID that uniquly identifies this operation. Usually the x-request-id
	// HTTP header of the request.
	//
	// Multiple events can belong to a single operation.
	//
	// When is this useful?
	//
	// Consider a Web request in a controller:
	//
	//	def start_job do
	//	  # running start operation ...
	//	end
	//
	// To add an Audit log to this operation, we can send it either before or
	// after the processing has been executed.
	//
	// 1) If we send it after the operation:
	//
	//	def start_job do
	//	  # running start operation ...
	//
	//	  Audit.log(:job, :start)
	//	end
	//
	//	We can risk the posibility that the processing is executed, but there is no
	//	Audit log saved. This can happen, for example, if the process shuts down
	//	just after the processing is done, but right before the log is sent out.
	//
	// 2) If we send it before the operation:
	//
	//	def start_job do
	//	  Audit.log(:job, :start)
	//
	//	  # running stop operation ...
	//	end
	//
	//	Now, we are certain that the Audit log is saved if the operation is
	//	executed. However, we would also like to save the ID of the job in the
	//	Audit log.
	//
	// 3) If we send both the start and the end.
	//
	//	def start_job do
	//	  Audit.log(:job, :start)
	//
	//	  # running stop operation ...
	//
	//	  Audit.log(:job, :start, job_id: id)
	//	end
	//
	//	This covers all the cases, however, the two events could be hard to
	//	connect while reviwing it.
	//
	// 4) Sending both at the start and the end with an operation_id.
	//
	//	def start_job do
	//	  Audit.log(:job, :start, operation_id: req.id)
	//
	//	  # running stop operation ...
	//
	//	  Audit.log(:job, :start, operation_id: req.id, job_id: id)
	//	end
	//
	//	By specifying the same operation_id, we have all the data and we can
	//	connect it.
	//
	// While generating the Audit Log dump, we can merge the events in the backend
	// and dump a single one to the customer.
	OperationId  string       `protobuf:"bytes,10,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	ResourceId   string       `protobuf:"bytes,11,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`            // [optional] ID of the resource that was modified.
	ResourceName string       `protobuf:"bytes,12,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"`      // [optional] Name of the resource that was modified.
	Medium       Event_Medium `protobuf:"varint,13,opt,name=medium,proto3,enum=InternalApi.Audit.Event_Medium" json:"medium,omitempty"` // [required] Web, API, or CLI
	// contains filtered or unexported fields
}

Cloud AMQP messages.

Listining for incomming logs on: 

exchange: 'audit'
routing-key: 'log'

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetDescription 

func (x *Event) GetDescription() string

func (*Event) GetIpAddress 

func (x *Event) GetIpAddress() string

func (*Event) GetMedium 

func (x *Event) GetMedium() Event_Medium

func (*Event) GetMetadata 

func (x *Event) GetMetadata() string

func (*Event) GetOperation 

func (x *Event) GetOperation() Event_Operation

func (*Event) GetOperationId 

func (x *Event) GetOperationId() string

func (*Event) GetOrgId 

func (x *Event) GetOrgId() string

func (*Event) GetResource 

func (x *Event) GetResource() Event_Resource

func (*Event) GetResourceId 

func (x *Event) GetResourceId() string

func (*Event) GetResourceName 

func (x *Event) GetResourceName() string

func (*Event) GetTimestamp 

func (x *Event) GetTimestamp() *timestamp.Timestamp

func (*Event) GetUserId 

func (x *Event) GetUserId() string

func (*Event) GetUsername 

func (x *Event) GetUsername() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type Event_Medium 

type Event_Medium int32
const (
	Event_Web Event_Medium = 0
	Event_API Event_Medium = 1
	Event_CLI Event_Medium = 2
)

func (Event_Medium) Descriptor 

func (Event_Medium) Descriptor() protoreflect.EnumDescriptor

func (Event_Medium) Enum 

func (x Event_Medium) Enum() *Event_Medium

func (Event_Medium) EnumDescriptor deprecated 

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

Deprecated: Use Event_Medium.Descriptor instead.

func (Event_Medium) Number 

func (x Event_Medium) Number() protoreflect.EnumNumber

func (Event_Medium) String 

func (x Event_Medium) String() string

func (Event_Medium) Type 

func (Event_Medium) Type() protoreflect.EnumType

type Event_Operation 

type Event_Operation int32
const (
	Event_Added    Event_Operation = 0
	Event_Removed  Event_Operation = 1
	Event_Modified Event_Operation = 2
	Event_Started  Event_Operation = 3
	Event_Stopped  Event_Operation = 4
	Event_Promoted Event_Operation = 5
	Event_Demoted  Event_Operation = 6
	Event_Rebuild  Event_Operation = 7
	Event_Download Event_Operation = 8
	Event_Disabled Event_Operation = 9
)

func (Event_Operation) Descriptor 

func (Event_Operation) Descriptor() protoreflect.EnumDescriptor

func (Event_Operation) Enum 

func (x Event_Operation) Enum() *Event_Operation

func (Event_Operation) EnumDescriptor deprecated 

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

Deprecated: Use Event_Operation.Descriptor instead.

func (Event_Operation) Number 

func (x Event_Operation) Number() protoreflect.EnumNumber

func (Event_Operation) String 

func (x Event_Operation) String() string

func (Event_Operation) Type 

func (Event_Operation) Type() protoreflect.EnumType

type Event_Resource 

type Event_Resource int32
const (
	Event_Project                 Event_Resource = 0
	Event_User                    Event_Resource = 1
	Event_Workflow                Event_Resource = 2
	Event_Pipeline                Event_Resource = 3
	Event_DebugSession            Event_Resource = 4
	Event_PeriodicScheduler       Event_Resource = 5
	Event_Secret                  Event_Resource = 6
	Event_Notification            Event_Resource = 7
	Event_Dashboard               Event_Resource = 8
	Event_Job                     Event_Resource = 9
	Event_Artifact                Event_Resource = 10
	Event_Organization            Event_Resource = 11
	Event_SelfHostedAgentType     Event_Resource = 12
	Event_SelfHostedAgent         Event_Resource = 13
	Event_CustomDashboard         Event_Resource = 14
	Event_CustomDashboardItem     Event_Resource = 15
	Event_ProjectInsightsSettings Event_Resource = 16
	Event_Okta                    Event_Resource = 17
	Event_FlakyTests              Event_Resource = 18
	Event_RBACRole                Event_Resource = 19
)

func (Event_Resource) Descriptor 

func (Event_Resource) Descriptor() protoreflect.EnumDescriptor

func (Event_Resource) Enum 

func (x Event_Resource) Enum() *Event_Resource

func (Event_Resource) EnumDescriptor deprecated 

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

Deprecated: Use Event_Resource.Descriptor instead.

func (Event_Resource) Number 

func (x Event_Resource) Number() protoreflect.EnumNumber

func (Event_Resource) String 

func (x Event_Resource) String() string

func (Event_Resource) Type 

func (Event_Resource) Type() protoreflect.EnumType

type ListRequest 

type ListRequest struct {
	OrgId string `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	// [optional]
	//
	// By default, only the last event for an operation is returned.
	// If you need every event, pass true.
	AllEventsInOperation bool `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetAllEventsInOperation 

func (x *ListRequest) GetAllEventsInOperation() bool

func (*ListRequest) GetOrgId 

func (x *ListRequest) GetOrgId() string

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListResponse 

type ListResponse struct {
	Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetEvents 

func (x *ListResponse) GetEvents() []*Event

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) String 

func (x *ListResponse) String() string

type ListStreamLogsRequest 

type ListStreamLogsRequest struct {
	OrgId     string                          `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	PageSize  int32                           `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken string                          `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	Direction ListStreamLogsRequest_Direction `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListStreamLogsRequest) Descriptor deprecated 

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

Deprecated: Use ListStreamLogsRequest.ProtoReflect.Descriptor instead.

func (*ListStreamLogsRequest) GetDirection 

func (x *ListStreamLogsRequest) GetDirection() ListStreamLogsRequest_Direction

func (*ListStreamLogsRequest) GetOrgId 

func (x *ListStreamLogsRequest) GetOrgId() string

func (*ListStreamLogsRequest) GetPageSize 

func (x *ListStreamLogsRequest) GetPageSize() int32

func (*ListStreamLogsRequest) GetPageToken 

func (x *ListStreamLogsRequest) GetPageToken() string

func (*ListStreamLogsRequest) ProtoMessage 

func (*ListStreamLogsRequest) ProtoMessage()

func (*ListStreamLogsRequest) ProtoReflect 

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

func (*ListStreamLogsRequest) Reset 

func (x *ListStreamLogsRequest) Reset()

func (*ListStreamLogsRequest) String 

func (x *ListStreamLogsRequest) String() string

type ListStreamLogsRequest_Direction 

type ListStreamLogsRequest_Direction int32
const (
	ListStreamLogsRequest_NEXT     ListStreamLogsRequest_Direction = 0
	ListStreamLogsRequest_PREVIOUS ListStreamLogsRequest_Direction = 1
)

func (ListStreamLogsRequest_Direction) Descriptor 

func (ListStreamLogsRequest_Direction) Descriptor() protoreflect.EnumDescriptor

func (ListStreamLogsRequest_Direction) Enum 

func (x ListStreamLogsRequest_Direction) Enum() *ListStreamLogsRequest_Direction

func (ListStreamLogsRequest_Direction) EnumDescriptor deprecated 

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

Deprecated: Use ListStreamLogsRequest_Direction.Descriptor instead.

func (ListStreamLogsRequest_Direction) Number 

func (x ListStreamLogsRequest_Direction) Number() protoreflect.EnumNumber

func (ListStreamLogsRequest_Direction) String 

func (x ListStreamLogsRequest_Direction) String() string

func (ListStreamLogsRequest_Direction) Type 

func (ListStreamLogsRequest_Direction) Type() protoreflect.EnumType

type ListStreamLogsResponse 

type ListStreamLogsResponse struct {
	StreamLogs        []*StreamLog `protobuf:"bytes,1,rep,name=stream_logs,json=streamLogs,proto3" json:"stream_logs,omitempty"`
	NextPageToken     string       `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	PreviousPageToken string       `protobuf:"bytes,3,opt,name=previous_page_token,json=previousPageToken,proto3" json:"previous_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStreamLogsResponse) Descriptor deprecated 

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

Deprecated: Use ListStreamLogsResponse.ProtoReflect.Descriptor instead.

func (*ListStreamLogsResponse) GetNextPageToken 

func (x *ListStreamLogsResponse) GetNextPageToken() string

func (*ListStreamLogsResponse) GetPreviousPageToken 

func (x *ListStreamLogsResponse) GetPreviousPageToken() string

func (*ListStreamLogsResponse) GetStreamLogs 

func (x *ListStreamLogsResponse) GetStreamLogs() []*StreamLog

func (*ListStreamLogsResponse) ProtoMessage 

func (*ListStreamLogsResponse) ProtoMessage()

func (*ListStreamLogsResponse) ProtoReflect 

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

func (*ListStreamLogsResponse) Reset 

func (x *ListStreamLogsResponse) Reset()

func (*ListStreamLogsResponse) String 

func (x *ListStreamLogsResponse) String() string

type PaginatedListRequest 

type PaginatedListRequest struct {
	OrgId     string                         `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	PageSize  int32                          `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken string                         `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	Direction PaginatedListRequest_Direction `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PaginatedListRequest) Descriptor deprecated 

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

Deprecated: Use PaginatedListRequest.ProtoReflect.Descriptor instead.

func (*PaginatedListRequest) GetDirection 

func (x *PaginatedListRequest) GetDirection() PaginatedListRequest_Direction

func (*PaginatedListRequest) GetOrgId 

func (x *PaginatedListRequest) GetOrgId() string

func (*PaginatedListRequest) GetPageSize 

func (x *PaginatedListRequest) GetPageSize() int32

func (*PaginatedListRequest) GetPageToken 

func (x *PaginatedListRequest) GetPageToken() string

func (*PaginatedListRequest) ProtoMessage 

func (*PaginatedListRequest) ProtoMessage()

func (*PaginatedListRequest) ProtoReflect 

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

func (*PaginatedListRequest) Reset 

func (x *PaginatedListRequest) Reset()

func (*PaginatedListRequest) String 

func (x *PaginatedListRequest) String() string

type PaginatedListRequest_Direction 

type PaginatedListRequest_Direction int32
const (
	PaginatedListRequest_NEXT     PaginatedListRequest_Direction = 0
	PaginatedListRequest_PREVIOUS PaginatedListRequest_Direction = 1
)

func (PaginatedListRequest_Direction) Descriptor 

func (PaginatedListRequest_Direction) Descriptor() protoreflect.EnumDescriptor

func (PaginatedListRequest_Direction) Enum 

func (x PaginatedListRequest_Direction) Enum() *PaginatedListRequest_Direction

func (PaginatedListRequest_Direction) EnumDescriptor deprecated 

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

Deprecated: Use PaginatedListRequest_Direction.Descriptor instead.

func (PaginatedListRequest_Direction) Number 

func (x PaginatedListRequest_Direction) Number() protoreflect.EnumNumber

func (PaginatedListRequest_Direction) String 

func (x PaginatedListRequest_Direction) String() string

func (PaginatedListRequest_Direction) Type 

func (PaginatedListRequest_Direction) Type() protoreflect.EnumType

type PaginatedListResponse 

type PaginatedListResponse struct {
	Events            []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	NextPageToken     string   `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	PreviousPageToken string   `protobuf:"bytes,3,opt,name=previous_page_token,json=previousPageToken,proto3" json:"previous_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*PaginatedListResponse) Descriptor deprecated 

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

Deprecated: Use PaginatedListResponse.ProtoReflect.Descriptor instead.

func (*PaginatedListResponse) GetEvents 

func (x *PaginatedListResponse) GetEvents() []*Event

func (*PaginatedListResponse) GetNextPageToken 

func (x *PaginatedListResponse) GetNextPageToken() string

func (*PaginatedListResponse) GetPreviousPageToken 

func (x *PaginatedListResponse) GetPreviousPageToken() string

func (*PaginatedListResponse) ProtoMessage 

func (*PaginatedListResponse) ProtoMessage()

func (*PaginatedListResponse) ProtoReflect 

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

func (*PaginatedListResponse) Reset 

func (x *PaginatedListResponse) Reset()

func (*PaginatedListResponse) String 

func (x *PaginatedListResponse) String() string

type S3StreamConfig 

type S3StreamConfig struct {
	Bucket    string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	KeyId     string `protobuf:"bytes,2,opt,name=key_id,json=keyId,proto3" json:"key_id,omitempty"`
	KeySecret string `protobuf:"bytes,3,opt,name=key_secret,json=keySecret,proto3" json:"key_secret,omitempty"`
	// specify host name of s3 server, defaults to aws
	Host   string              `protobuf:"bytes,4,opt,name=host,proto3" json:"host,omitempty"`
	Region string              `protobuf:"bytes,5,opt,name=region,proto3" json:"region,omitempty"`
	Type   S3StreamConfig_Type `protobuf:"varint,6,opt,name=type,proto3,enum=InternalApi.Audit.S3StreamConfig_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*S3StreamConfig) Descriptor deprecated 

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

Deprecated: Use S3StreamConfig.ProtoReflect.Descriptor instead.

func (*S3StreamConfig) GetBucket 

func (x *S3StreamConfig) GetBucket() string

func (*S3StreamConfig) GetHost 

func (x *S3StreamConfig) GetHost() string

func (*S3StreamConfig) GetKeyId 

func (x *S3StreamConfig) GetKeyId() string

func (*S3StreamConfig) GetKeySecret 

func (x *S3StreamConfig) GetKeySecret() string

func (*S3StreamConfig) GetRegion 

func (x *S3StreamConfig) GetRegion() string

func (*S3StreamConfig) GetType 

func (x *S3StreamConfig) GetType() S3StreamConfig_Type

func (*S3StreamConfig) ProtoMessage 

func (*S3StreamConfig) ProtoMessage()

func (*S3StreamConfig) ProtoReflect 

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

func (*S3StreamConfig) Reset 

func (x *S3StreamConfig) Reset()

func (*S3StreamConfig) String 

func (x *S3StreamConfig) String() string

type S3StreamConfig_Type 

type S3StreamConfig_Type int32

Describes the type of S3StreamConfig - USER - uses key_id and key_secret as credential - INSTANCE_ROLE - uses AWS instance role to access S3 

const (
	S3StreamConfig_USER          S3StreamConfig_Type = 0
	S3StreamConfig_INSTANCE_ROLE S3StreamConfig_Type = 1
)

func (S3StreamConfig_Type) Descriptor 

func (S3StreamConfig_Type) Descriptor() protoreflect.EnumDescriptor

func (S3StreamConfig_Type) Enum 

func (x S3StreamConfig_Type) Enum() *S3StreamConfig_Type

func (S3StreamConfig_Type) EnumDescriptor deprecated 

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

Deprecated: Use S3StreamConfig_Type.Descriptor instead.

func (S3StreamConfig_Type) Number 

func (x S3StreamConfig_Type) Number() protoreflect.EnumNumber

func (S3StreamConfig_Type) String 

func (x S3StreamConfig_Type) String() string

func (S3StreamConfig_Type) Type 

func (S3StreamConfig_Type) Type() protoreflect.EnumType

type SetStreamStateRequest 

type SetStreamStateRequest struct {
	OrgId  string       `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	Status StreamStatus `protobuf:"varint,2,opt,name=status,proto3,enum=InternalApi.Audit.StreamStatus" json:"status,omitempty"`
	UserId string       `protobuf:"bytes,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SetStreamStateRequest) Descriptor deprecated 

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

Deprecated: Use SetStreamStateRequest.ProtoReflect.Descriptor instead.

func (*SetStreamStateRequest) GetOrgId 

func (x *SetStreamStateRequest) GetOrgId() string

func (*SetStreamStateRequest) GetStatus 

func (x *SetStreamStateRequest) GetStatus() StreamStatus

func (*SetStreamStateRequest) GetUserId 

func (x *SetStreamStateRequest) GetUserId() string

func (*SetStreamStateRequest) ProtoMessage 

func (*SetStreamStateRequest) ProtoMessage()

func (*SetStreamStateRequest) ProtoReflect 

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

func (*SetStreamStateRequest) Reset 

func (x *SetStreamStateRequest) Reset()

func (*SetStreamStateRequest) String 

func (x *SetStreamStateRequest) String() string

type Stream 

type Stream struct {
	OrgId    string         `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	Provider StreamProvider `protobuf:"varint,2,opt,name=provider,proto3,enum=InternalApi.Audit.StreamProvider" json:"provider,omitempty"`
	Status   StreamStatus   `protobuf:"varint,3,opt,name=status,proto3,enum=InternalApi.Audit.StreamStatus" json:"status,omitempty"`
	// based on provider one of the following fields should be set
	S3Config *S3StreamConfig `protobuf:"bytes,4,opt,name=s3_config,json=s3Config,proto3" json:"s3_config,omitempty"`
	// contains filtered or unexported fields
}

Stream is message used to describe one stream

func (*Stream) Descriptor deprecated 

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

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetOrgId 

func (x *Stream) GetOrgId() string

func (*Stream) GetProvider 

func (x *Stream) GetProvider() StreamProvider

func (*Stream) GetS3Config 

func (x *Stream) GetS3Config() *S3StreamConfig

func (*Stream) GetStatus 

func (x *Stream) GetStatus() StreamStatus

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect 

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

func (*Stream) Reset 

func (x *Stream) Reset()

func (*Stream) String 

func (x *Stream) String() string

type StreamLog 

type StreamLog struct {
	Timestamp           *timestamp.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ErrorMessage        string               `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	FileSize            int32                `protobuf:"varint,3,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
	FileName            string               `protobuf:"bytes,4,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	FirstEventTimestamp *timestamp.Timestamp `protobuf:"bytes,5,opt,name=first_event_timestamp,json=firstEventTimestamp,proto3" json:"first_event_timestamp,omitempty"`
	LastEventTimestamp  *timestamp.Timestamp `protobuf:"bytes,6,opt,name=last_event_timestamp,json=lastEventTimestamp,proto3" json:"last_event_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamLog) Descriptor deprecated 

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

Deprecated: Use StreamLog.ProtoReflect.Descriptor instead.

func (*StreamLog) GetErrorMessage 

func (x *StreamLog) GetErrorMessage() string

func (*StreamLog) GetFileName 

func (x *StreamLog) GetFileName() string

func (*StreamLog) GetFileSize 

func (x *StreamLog) GetFileSize() int32

func (*StreamLog) GetFirstEventTimestamp 

func (x *StreamLog) GetFirstEventTimestamp() *timestamp.Timestamp

func (*StreamLog) GetLastEventTimestamp 

func (x *StreamLog) GetLastEventTimestamp() *timestamp.Timestamp

func (*StreamLog) GetTimestamp 

func (x *StreamLog) GetTimestamp() *timestamp.Timestamp

func (*StreamLog) ProtoMessage 

func (*StreamLog) ProtoMessage()

func (*StreamLog) ProtoReflect 

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

func (*StreamLog) Reset 

func (x *StreamLog) Reset()

func (*StreamLog) String 

func (x *StreamLog) String() string

type StreamProvider 

type StreamProvider int32

export stream provider in audit service 

const (
	StreamProvider_S3 StreamProvider = 0
)

func (StreamProvider) Descriptor 

func (StreamProvider) Descriptor() protoreflect.EnumDescriptor

func (StreamProvider) Enum 

func (x StreamProvider) Enum() *StreamProvider

func (StreamProvider) EnumDescriptor deprecated 

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

Deprecated: Use StreamProvider.Descriptor instead.

func (StreamProvider) Number 

func (x StreamProvider) Number() protoreflect.EnumNumber

func (StreamProvider) String 

func (x StreamProvider) String() string

func (StreamProvider) Type 

func (StreamProvider) Type() protoreflect.EnumType

type StreamStatus 

type StreamStatus int32
const (
	StreamStatus_ACTIVE StreamStatus = 0
	StreamStatus_PAUSED StreamStatus = 1
)

func (StreamStatus) Descriptor 

func (StreamStatus) Descriptor() protoreflect.EnumDescriptor

func (StreamStatus) Enum 

func (x StreamStatus) Enum() *StreamStatus

func (StreamStatus) EnumDescriptor deprecated 

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

Deprecated: Use StreamStatus.Descriptor instead.

func (StreamStatus) Number 

func (x StreamStatus) Number() protoreflect.EnumNumber

func (StreamStatus) String 

func (x StreamStatus) String() string

func (StreamStatus) Type 

func (StreamStatus) Type() protoreflect.EnumType

type TestStreamRequest 

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

func (*TestStreamRequest) Descriptor deprecated 

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

Deprecated: Use TestStreamRequest.ProtoReflect.Descriptor instead.

func (*TestStreamRequest) GetStream 

func (x *TestStreamRequest) GetStream() *Stream

func (*TestStreamRequest) ProtoMessage 

func (*TestStreamRequest) ProtoMessage()

func (*TestStreamRequest) ProtoReflect 

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

func (*TestStreamRequest) Reset 

func (x *TestStreamRequest) Reset()

func (*TestStreamRequest) String 

func (x *TestStreamRequest) String() string

type TestStreamResponse 

type TestStreamResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*TestStreamResponse) Descriptor deprecated 

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

Deprecated: Use TestStreamResponse.ProtoReflect.Descriptor instead.

func (*TestStreamResponse) GetMessage 

func (x *TestStreamResponse) GetMessage() string

func (*TestStreamResponse) GetSuccess 

func (x *TestStreamResponse) GetSuccess() bool

func (*TestStreamResponse) ProtoMessage 

func (*TestStreamResponse) ProtoMessage()

func (*TestStreamResponse) ProtoReflect 

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

func (*TestStreamResponse) Reset 

func (x *TestStreamResponse) Reset()

func (*TestStreamResponse) String 

func (x *TestStreamResponse) String() string

type UnimplementedAuditServiceServer 

type UnimplementedAuditServiceServer struct{}

UnimplementedAuditServiceServer should 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 (UnimplementedAuditServiceServer) CreateStream 

func (UnimplementedAuditServiceServer) CreateStream(context.Context, *CreateStreamRequest) (*CreateStreamResponse, error)

func (UnimplementedAuditServiceServer) DescribeStream 

func (UnimplementedAuditServiceServer) DescribeStream(context.Context, *DescribeStreamRequest) (*DescribeStreamResponse, error)

func (UnimplementedAuditServiceServer) DestroyStream 

func (UnimplementedAuditServiceServer) DestroyStream(context.Context, *DestroyStreamRequest) (*empty.Empty, error)

func (UnimplementedAuditServiceServer) List 

func (UnimplementedAuditServiceServer) List(context.Context, *ListRequest) (*ListResponse, error)

func (UnimplementedAuditServiceServer) ListStreamLogs 

func (UnimplementedAuditServiceServer) ListStreamLogs(context.Context, *ListStreamLogsRequest) (*ListStreamLogsResponse, error)

func (UnimplementedAuditServiceServer) PaginatedList 

func (UnimplementedAuditServiceServer) PaginatedList(context.Context, *PaginatedListRequest) (*PaginatedListResponse, error)

func (UnimplementedAuditServiceServer) SetStreamState 

func (UnimplementedAuditServiceServer) SetStreamState(context.Context, *SetStreamStateRequest) (*empty.Empty, error)

func (UnimplementedAuditServiceServer) TestStream 

func (UnimplementedAuditServiceServer) TestStream(context.Context, *TestStreamRequest) (*TestStreamResponse, error)

func (UnimplementedAuditServiceServer) UpdateStream 

func (UnimplementedAuditServiceServer) UpdateStream(context.Context, *UpdateStreamRequest) (*UpdateStreamResponse, error)

type UnsafeAuditServiceServer 

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

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

type UpdateStreamRequest 

type UpdateStreamRequest struct {
	Stream *Stream `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	UserId string  `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateStreamRequest) Descriptor deprecated 

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

Deprecated: Use UpdateStreamRequest.ProtoReflect.Descriptor instead.

func (*UpdateStreamRequest) GetStream 

func (x *UpdateStreamRequest) GetStream() *Stream

func (*UpdateStreamRequest) GetUserId 

func (x *UpdateStreamRequest) GetUserId() string

func (*UpdateStreamRequest) ProtoMessage 

func (*UpdateStreamRequest) ProtoMessage()

func (*UpdateStreamRequest) ProtoReflect 

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

func (*UpdateStreamRequest) Reset 

func (x *UpdateStreamRequest) Reset()

func (*UpdateStreamRequest) String 

func (x *UpdateStreamRequest) String() string

type UpdateStreamResponse 

type UpdateStreamResponse struct {
	Stream *Stream   `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	Meta   *EditMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateStreamResponse) Descriptor deprecated 

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

Deprecated: Use UpdateStreamResponse.ProtoReflect.Descriptor instead.

func (*UpdateStreamResponse) GetMeta 

func (x *UpdateStreamResponse) GetMeta() *EditMeta

func (*UpdateStreamResponse) GetStream 

func (x *UpdateStreamResponse) GetStream() *Stream

func (*UpdateStreamResponse) ProtoMessage 

func (*UpdateStreamResponse) ProtoMessage()

func (*UpdateStreamResponse) ProtoReflect 

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

func (*UpdateStreamResponse) Reset 

func (x *UpdateStreamResponse) Reset()

func (*UpdateStreamResponse) String 

func (x *UpdateStreamResponse) 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.