Method setEncodedWithContext

shared_state.go:283–306

(
	ctx context.Context,
	key string,
	v any,
	ttl time.Duration,
	encoder func(any) ([]byte, error),
	format string,
)

}

func (s *SharedState) setEncodedWithContext(
	ctx context.Context,
	key string,
	v any,
	ttl time.Duration,
	encoder func(any) ([]byte, error),
	format string,
) error {
	if err := s.ensureStorage(); err != nil {
		return err
	}

	storageKey, ok := s.storageKey(key)
	if !ok {
		return nil
	}

	encoded, err := encodeSharedStateValue(v, encoder, format)
	if err != nil {
		return err
	}

	return s.storage.SetWithContext(ctx, storageKey, encoded, ttl)
}

// getEncodedWithContext returns a defensive copy of the encoded payload after
// decoding it into out, so callers can safely mutate the returned slice.