hallmarkv1

type AppendRequest struct {

	// event is the audit event to record.
	Event *AuditEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

type AppendResponse struct {

	// id is the server-assigned UUID of the recorded event.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type AppendStreamRequest struct {

	// event is the audit event to record.
	Event *AuditEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

type AppendStreamResponse struct {

	// count is the number of events persisted by the stream.
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

type AuditEvent struct {

	// id is the server-assigned UUID of the event.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// timestamp is when the event occurred (server-defaulted when unset).
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// realm_id is the optional tenant the event belongs to.
	RealmId string `protobuf:"bytes,3,opt,name=realm_id,json=realmId,proto3" json:"realm_id,omitempty"`
	// actor_id identifies who performed the action.
	ActorId string `protobuf:"bytes,4,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	// actor_type classifies the actor (e.g. user, service, system).
	ActorType string `protobuf:"bytes,5,opt,name=actor_type,json=actorType,proto3" json:"actor_type,omitempty"`
	// resource_type is the kind of resource the action targeted.
	ResourceType string `protobuf:"bytes,6,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
	// resource_id is the id of the resource the action targeted.
	ResourceId string `protobuf:"bytes,7,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// action is the verb describing what happened (required).
	Action string `protobuf:"bytes,8,opt,name=action,proto3" json:"action,omitempty"`
	// summary is a short human-readable description of the event.
	Summary string `protobuf:"bytes,9,opt,name=summary,proto3" json:"summary,omitempty"`
	// changes is a structured before/after diff of the resource.
	Changes *structpb.Struct `protobuf:"bytes,10,opt,name=changes,proto3" json:"changes,omitempty"`
	// metadata is free-form structured context attached by the emitter.
	Metadata *structpb.Struct `protobuf:"bytes,11,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// ip is the source IP address associated with the action.
	Ip string `protobuf:"bytes,12,opt,name=ip,proto3" json:"ip,omitempty"`
	// request_id correlates the event with an upstream request.
	RequestId string `protobuf:"bytes,13,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

type HallmarkServiceClient interface {
	// Append records a single audit event and returns its server-assigned id.
	Append(ctx context.Context, in *AppendRequest, opts ...grpc.CallOption) (*AppendResponse, error)
	// AppendStream records a batch of audit events from a client stream and
	// returns how many were persisted.
	AppendStream(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[AppendStreamRequest, AppendStreamResponse], error)
	// Query returns audit events matching the given filter, newest first.
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	// Subscribe streams matching audit events. When replay_from is set the
	// server first replays matching history (oldest first) and then continues
	// with live events as they are appended, until the client disconnects.
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SubscribeResponse], error)
}

type HallmarkServiceServer interface {
	// Append records a single audit event and returns its server-assigned id.
	Append(context.Context, *AppendRequest) (*AppendResponse, error)
	// AppendStream records a batch of audit events from a client stream and
	// returns how many were persisted.
	AppendStream(grpc.ClientStreamingServer[AppendStreamRequest, AppendStreamResponse]) error
	// Query returns audit events matching the given filter, newest first.
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	// Subscribe streams matching audit events. When replay_from is set the
	// server first replays matching history (oldest first) and then continues
	// with live events as they are appended, until the client disconnects.
	Subscribe(*SubscribeRequest, grpc.ServerStreamingServer[SubscribeResponse]) error
}

type HallmarkService_AppendStreamClient = grpc.ClientStreamingClient[AppendStreamRequest, AppendStreamResponse]

type HallmarkService_AppendStreamServer = grpc.ClientStreamingServer[AppendStreamRequest, AppendStreamResponse]

type HallmarkService_SubscribeClient = grpc.ServerStreamingClient[SubscribeResponse]

type HallmarkService_SubscribeServer = grpc.ServerStreamingServer[SubscribeResponse]

type QueryRequest struct {

	// actor_id filters to events performed by this actor.
	ActorId string `protobuf:"bytes,1,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	// resource_type filters to events targeting this resource kind.
	ResourceType string `protobuf:"bytes,2,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
	// resource_id filters to events targeting this resource id.
	ResourceId string `protobuf:"bytes,3,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// action filters to events with this action verb.
	Action string `protobuf:"bytes,4,opt,name=action,proto3" json:"action,omitempty"`
	// from bounds the result set to events at or after this time.
	From *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=from,proto3" json:"from,omitempty"`
	// to bounds the result set to events at or before this time.
	To *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=to,proto3" json:"to,omitempty"`
	// limit caps the number of returned events.
	Limit uint32 `protobuf:"varint,7,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type QueryResponse struct {

	// events are the matched audit events, newest first.
	Events []*AuditEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// total_count is the number of events matching the filter.
	TotalCount uint32 `protobuf:"varint,2,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// contains filtered or unexported fields
}

type SubscribeRequest struct {

	// actor_id filters to events performed by this actor.
	ActorId string `protobuf:"bytes,1,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	// resource_type filters to events targeting this resource kind.
	ResourceType string `protobuf:"bytes,2,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
	// resource_id filters to events targeting this resource id.
	ResourceId string `protobuf:"bytes,3,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// action filters to events with this action verb.
	Action string `protobuf:"bytes,4,opt,name=action,proto3" json:"action,omitempty"`
	// replay_from, when set, replays matching history at or after this time
	// before switching to the live tail.
	ReplayFrom *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=replay_from,json=replayFrom,proto3" json:"replay_from,omitempty"`
	// replay_limit caps the number of replayed history events.
	ReplayLimit uint32 `protobuf:"varint,6,opt,name=replay_limit,json=replayLimit,proto3" json:"replay_limit,omitempty"`
	// contains filtered or unexported fields
}

type SubscribeResponse struct {

	// event is the streamed audit event (replayed or live).
	Event *AuditEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedHallmarkServiceServer struct{}

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